[ https://issues.apache.org/jira/browse/KAFKA-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635609#comment-16635609 ]
Dong Lin commented on KAFKA-5030: --------------------------------- Moving this to 2.2.0 since PR is not ready yet. > Suggested clean-ups from message format V2 review > ------------------------------------------------- > > Key: KAFKA-5030 > URL: https://issues.apache.org/jira/browse/KAFKA-5030 > Project: Kafka > Issue Type: Sub-task > Components: clients, core, producer > Reporter: Ismael Juma > Priority: Major > Labels: exactly-once > Fix For: 2.1.0 > > > A few random clean-ups raised during the review of the message format V2 PR: > 1. We should use magic or message format version consistently. It seems like > we are moving towards the former. > 2. We should consider moving Log.analyzeAndValidateRecords to LogValidator so > that the validation logic is all in the same class. > 3. MemoryRecords.toString should include batch information, it currently only > includes records information. > 4. Record.hasMagic should be hasCompatibleMagic to make the behaviour > clearer. For version 2, it returns true if the passed magic is greater than > or equal to 2. > 5. Once we move to Java 8, move AbstractRecordBatch's methods to RecordBatch > (i.e. default methods) and remove AbstractRecordBatch. > 6. Consider moving some of the down-conversion logic from KafkaApis to > FetchRequest so that it can be more easily unit testable. -- This message was sent by Atlassian JIRA (v7.6.3#76005)