解決方式:手動刪除\kafka-logs里的日志文件重啟kafka
2、出現兩個Consumer同時消費同一個topic下面的同一個group,只有一個能夠讀取到數據:
原因:
相同的group下面的消費者訪問的東西不會重復,而且如果一個partition對應一個consumer,如果consumer的數量大於Topic中partition的數量就會有的consumer接不到數據。所以當出現業務需求,要增加消費者數量的時候,需要考慮是否先增加partition的數量先。
不同的group下面的消費者互補影響,因此可以實現相同的數據,給不同的消費者進行處理,做不同的事情。
————————————————
版權聲明:本文為CSDN博主「maslii」的原創文章,遵循CC 4.0 BY-SA版權協議,轉載請附上原文出處鏈接及本聲明。
原文鏈接:https://blog.csdn.net/Maslii/article/details/104842608