[ https://issues.apache.org/jira/browse/KAFKA-9872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lee chen updated KAFKA-9872: ---------------------------- Affects Version/s: 2.0.0 2.1.0 2.2.0 2.1.1 2.3.0 2.4.0 > After restart kafka by a abnormal way,kafkaconsumer cannot read messages > -------------------------------------------------------------------------- > > Key: KAFKA-9872 > URL: https://issues.apache.org/jira/browse/KAFKA-9872 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 1.1.0, 2.0.0, 2.1.0, 2.2.0, 2.1.1, 2.3.0, 2.4.0 > Reporter: Lee chen > Priority: Major > > Recently, I face a problem of a broker restart by server shutdown directly. > when I restart the broker, I found my consumer cannot read data. > 1,My consumer group named "0",and The partitions of __consumer_offsets is 50. > 2,As the Calculation results of kafka. The partition of consumer "0" is in > partition-48 > 3, kafkaConsumer belong to consumer group “0” cannot read datas ,but when I > change to another group which not in partition-48, all consumers are back to > normal.It seems that* the log dir of partition-48 belong to > __consumer_offsets is damaged*. > 4,When I check the log dir of __consumer_offsets-48,I* found so many .snap > files. * > 5,I found the nummber recorded in latest log file in __consumer_offsets-48 > is smaller than the nummber recorded in recovery-point-offset-checkpoint and > replication-offset-checkpoint > 6,I use kafka-topics.sh to describe __consumer_offsets is normal,All replica > is be contained in ISR. > As my understanding,If log dir is damaged, the broker may be cannot restart. -- This message was sent by Atlassian Jira (v8.3.4#803005)