public interface KafkaConsumerRecord<K,V>
Modifier and Type | Method and Description |
---|---|
long |
checksum()
Deprecated.
As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the
checksum returned by the broker may not match what was computed by the producer.
It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally,
message format v2 does not include a record-level checksum (for performance, the record checksum
was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from
the record timestamp, serialized key size, and serialized value size is returned instead, but
this should not be depended on for end-to-end reliability.
|
List<KafkaHeader> |
headers() |
K |
key() |
long |
offset() |
int |
partition() |
org.apache.kafka.clients.consumer.ConsumerRecord<K,V> |
record() |
long |
timestamp() |
org.apache.kafka.common.record.TimestampType |
timestampType() |
String |
topic() |
V |
value() |
String topic()
int partition()
long offset()
long timestamp()
org.apache.kafka.common.record.TimestampType timestampType()
@Deprecated long checksum()
K key()
V value()
List<KafkaHeader> headers()
Copyright © 2022 Eclipse. All rights reserved.