KIP-641 — An new java interface to replace 'kafka.common.MessageReader'

Accepted Kafka 3.5 Admin

Introduces a new public Java interface org.apache.kafka.tools.api.RecordReader in a new tools-api module to replace the internal Scala kafka.common.MessageReader used as a pluggable input format for kafka-console-producer. The existing MessageReader was implemented in Scala and located in the core module, making it inaccessible to Java-based custom implementations and tightly coupled to internal Kafka internals.

Details