Lee chen created KAFKA-9872:
-------------------------------
Summary: 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
Reporter: Lee chen
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)