Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
We now have 2 OffsetAndMetadata classes that are almost identical:
- kafka.common.OffsetAndMetadata
- org.apache.kafka.coordinator.group.OffsetAndMetadata
(There's a 3rd class, org.apache.kafka.clients.consumer.OffsetAndMetadata, but it serves a different purpose)
We should get rid of the Scala class (kafka.common.OffsetAndMetadata) and use org.apache.kafka.coordinator.group.OffsetAndMetadata everywhere. This would also help migrate a bunch of classes (Partition, ReplicaManager) out of the core module.
Attachments
Issue Links
- links to