KAFKA-10244 An new java interface to replace 'kafka.common.MessageReader'

[chia7712]

related to https://issues.apache.org/jira/browse/KAFKA-10244

kafka.common.MessageReader is a input argument of kafka-console-producer and we expect users can have their custom reader to produce custom records. Hence, MessageReader is a public interface and we should offer a java version to replace current scala code. Also, the new MessageReader should be placed at clients module. (kafka.common.MessageReader is in core module)

Committer Checklist (excluded from commit message)

• Verify design and implementation
• Verify test coverage and CI build status
• Verify documentation (including upgrade notes)

[mimaison]

Thanks for the PR! I left a few comments.

[chia7712]

@mimaison thanks for reviews. I have addressed all comments. please take a look, thanks!

[mimaison]

Thanks for the updates. LGTM

[chia7712]

[2023-03-23T20:27:39.266Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 182 > PlaintextAdminIntegrationTest > testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String) > kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String)[2] FAILED
[2023-03-23T20:27:39.266Z]     java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: The request timed out.
[2023-03-23T20:27:39.266Z]         at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
[2023-03-23T20:27:39.266Z]         at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
[2023-03-23T20:27:39.266Z]         at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
[2023-03-23T20:27:39.266Z]         at kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(PlaintextAdminIntegrationTest.scala:859)
[2023-03-23T20:27:39.266Z] 
[2023-03-23T20:27:39.266Z]         Caused by:
[2023-03-23T20:27:39.267Z]         org.apache.kafka.common.errors.TimeoutException: The request timed out.

unrelated error. will merge it later

[ijuma]

Since this is a public api, we need to enable javadoc generation for it. Have we done that?

[ijuma]

One additional issue is that we are introducing a new "split packages" situation. We already have some of those, but we should probably not add new ones for public apis due to https://www.logicbig.com/tutorials/core-java-tutorial/modules/split-packages.html

[chia7712]

we need to enable javadoc generation for it. Have we done that?

I will address it later.

should probably not add new ones for public apis due to https://www.logicbig.com/tutorials/core-java-tutorial/modules/split-packages.html

thanks for nice reminder. the alternative is org.apache.kafka.common ( same as MessageFormatter). The side effect is that we have to add allow rule for importing ProducerRecord. WDYT?