Package io.smallrye.reactive.messaging.kafka

Class OutgoingKafkaRecordMetadata<K>

java.lang.Object

io.smallrye.reactive.messaging.kafka.api.OutgoingKafkaRecordMetadata<K>

io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata<K>

All Implemented Interfaces:

KafkaMessageMetadata<K>, KafkaMessageMetadata<K>

@Deprecated
public class OutgoingKafkaRecordMetadata<K>
extends OutgoingKafkaRecordMetadata<K>
implements KafkaMessageMetadata<K>

Deprecated.

use OutgoingKafkaRecordMetadata instead

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	Deprecated.

Constructor Summary

Constructors

Constructor	Description
OutgoingKafkaRecordMetadata(String topic, K key, int partition, Instant timestamp, org.apache.kafka.common.header.Headers headers)	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	builder()	Deprecated.

Methods inherited from class io.smallrye.reactive.messaging.kafka.api.OutgoingKafkaRecordMetadata

getHeaders, getKey, getPartition, getTimestamp, getTopic

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.smallrye.reactive.messaging.kafka.api.KafkaMessageMetadata

getHeaders, getKey, getPartition, getTimestamp, getTopic

Constructor Detail

OutgoingKafkaRecordMetadata

public OutgoingKafkaRecordMetadata(String topic,
                                   K key,
                                   int partition,
                                   Instant timestamp,
                                   org.apache.kafka.common.header.Headers headers)

Deprecated.

Method Detail

builder

public static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> builder()

Deprecated.