org.axonframework.kafka.eventhandling.consumer

Interface KafkaMetadataProvider<V>

All Known Implementing Classes:

KafkaEventMessage

public interface KafkaMetadataProvider<V>

An interface for messages originating from Kafka capable of providing information about their source.

Author:

Nakul Mishra.

Method Summary

Modifier and Type	Method and Description
long	offset() The position of record in the corresponding Kafka partition.
int	partition() The partition from which record is received
long	timestamp() The timestamp of record
V	value() The value

Method Detail

partition

int partition()

The partition from which record is received

offset

long offset()

The position of record in the corresponding Kafka partition.

timestamp

long timestamp()

The timestamp of record

value

V value()

The value