Advice on how to comprehend Kafka source code

Hi community, After being a Kafka user for several years, I want to know Kafka better maybe on a code level. I am wondering if anyone can give me any advice. To be more specific, I am thinking about the following things. 0. Is reading source code the best way to learn more about Kafka ? 1. Which

[jira] [Created] (KAFKA-17884) SLF4J error when running Kafka in IDEA

Xiang Zhang created KAFKA-17884: --- Summary: SLF4J error when running Kafka in IDEA Key: KAFKA-17884 URL: https://issues.apache.org/jira/browse/KAFKA-17884 Project: Kafka Issue Type: Wish

SLF4J error when running Kafka in IDEA

setup or this can be fixed or avoided out of the box. I would love your thoughts on this. Thanks ! Xiang Zhang xiangzhang1...@gmail.com

Re: doc clarification about meesage format

I think there is an intentional use for this historical leadership data in the log [1]. [1] https://cwiki.apache.org/confluence/display/KAFKA/KIP-101+-+Alter+Replication+Protocol+to+use+Leader+Epoch+rather+than+High+Watermark+for+Truncation Thanks, Greg On Wed, Oct 23, 2024 at 8:07 PM Xiang Zhang

Re: doc clarification about meesage format

130f121e75ccba2d913bdffa358cf3867/clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java#L385-L387 > > > On Tue, Oct 22, 2024 at 7:51 PM Xiang Zhang > wrote: > > > Hi all, > > > > I am reading official doc here: > > https://kafka.apache.org/documentatio

doc clarification about meesage format

need to recompute the CRC when this field is assigned for every batch that is received by the broker. I just don’t really get what the highlight part is trying to say. Regards, Xiang Zhang

[jira] [Resolved] (KAFKA-9906) Is bytesSinceLastIndexEntry updated correctly in LogSegment.append()?

[ https://issues.apache.org/jira/browse/KAFKA-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiang Zhang resolved KAFKA-9906. Resolution: Not A Problem > Is bytesSinceLastIndexEntry updated correctly in LogSegment.app

[jira] [Created] (KAFKA-9906) Is bytesSinceLastIndexEntry updated correct when LogSegment.append() is called ?

Xiang Zhang created KAFKA-9906: -- Summary: Is bytesSinceLastIndexEntry updated correct when LogSegment.append() is called ? Key: KAFKA-9906 URL: https://issues.apache.org/jira/browse/KAFKA-9906 Project

[jira] [Resolved] (KAFKA-9236) Confused log after using CLI scripts to produce messages

[ https://issues.apache.org/jira/browse/KAFKA-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiang Zhang resolved KAFKA-9236. Resolution: Fixed > Confused log after using CLI scripts to produce messa

[jira] [Created] (KAFKA-9236) Confused log after using CLI scripts to produce messages

Xiang Zhang created KAFKA-9236: -- Summary: Confused log after using CLI scripts to produce messages Key: KAFKA-9236 URL: https://issues.apache.org/jira/browse/KAFKA-9236 Project: Kafka Issue