Skip to main content

Module record

Module record 

Source
Expand description

Provides utility components related to Kafka records (org.apache.kafka.common.record).

In Kafka 4.3.1 (KAFKA-20128) the low-level record and record-batch representation moved to the internal submodule (org.apache.kafka.common.record.internal). Only TimestampType stays in this package. InvalidRecordError mirrors org.apache.kafka.common.InvalidRecordException (never a record-package type in Java; kept here for its long-standing Rust home).

Enumsยง

TimestampType
The timestamp type of the records.