IncomingKafkaRecordMetadata (SmallRye Reactive Messaging 2.2.1 API)

java.lang.Object
- io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata<K,T>

All Implemented Interfaces:: KafkaMessageMetadata<K>

public class IncomingKafkaRecordMetadata<K,T>
extends Object
implements KafkaMessageMetadata<K>

Constructor Summary

Constructors
Constructor Description

IncomingKafkaRecordMetadata(io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.kafka.common.header.Headers`	`getHeaders()`
`K`	`getKey()`
`long`	`getOffset()`
`int`	`getPartition()`
`io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T>`	`getRecord()`
`Instant`	`getTimestamp()`
`org.apache.kafka.common.record.TimestampType`	`getTimestampType()`
`String`	`getTopic()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IncomingKafkaRecordMetadata

public IncomingKafkaRecordMetadata(io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record)

Method Detail
- getTopic
```
public String getTopic()
```
  Specified by:
  
  getTopic in interface KafkaMessageMetadata<K>
- getKey
```
public K getKey()
```
  Specified by:
  
  getKey in interface KafkaMessageMetadata<K>
- getPartition
```
public int getPartition()
```
  Specified by:
  
  getPartition in interface KafkaMessageMetadata<K>
- getTimestamp
```
public Instant getTimestamp()
```
  Specified by:
  
  getTimestamp in interface KafkaMessageMetadata<K>
- getTimestampType
```
public org.apache.kafka.common.record.TimestampType getTimestampType()
```
- getOffset
```
public long getOffset()
```
- getHeaders
```
public org.apache.kafka.common.header.Headers getHeaders()
```
  Specified by:
  
  getHeaders in interface KafkaMessageMetadata<K>
- getRecord
```
public io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> getRecord()
```