Package io.smallrye.reactive.messaging.kafka

Class IncomingKafkaRecordMetadata<K,T>

java.lang.Object

io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata<K,T>

io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata<K,T>

All Implemented Interfaces:

KafkaMessageMetadata<K>, KafkaMessageMetadata<K>

@Deprecated
public class IncomingKafkaRecordMetadata<K,T>
extends IncomingKafkaRecordMetadata<K,T>
implements KafkaMessageMetadata<K>

Deprecated.

use IncomingKafkaRecordMetadata instead

Constructor Summary

Constructors

Constructor	Description
IncomingKafkaRecordMetadata(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)	Deprecated.

Method Summary

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

getHeaders, getKey, getOffset, getPartition, getRecord, getTimestamp, getTimestampType, 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

IncomingKafkaRecordMetadata

public IncomingKafkaRecordMetadata(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)

Deprecated.