Комментарии 5
Прежде чем писать статью, постарайтесь разобраться в теме. При acks=1 подтверждение ожидается не от консьюмера, а от лидера. При acks=all от всех in-sync реплик, а не как написано синхронизированная реплика остаётся активной, что это вообще значит. Остальные ошибки исправляйте сами.
Ошибка в примере кода: вроде говорим за ошибку продьюсера, а код приведен для консьюмера, да и тот кривоват.
Да и про zookeeper следовало бы упомянуть...
Kafka 4.0 will be fully saying goodbye to ZooKeeper. There will be no support for running in ZK mode, or migrating from ZK mode.
За статью спасибо!
+1 проблема в список: консьюмер, который забирает сообщения в цикле while (true) без пауз. Пока работа есть - всё хорошо, пацзы возникают сами собой от её выполнения. Но как только работа заканчивается… приложения долбят кафку, кафка бодро им отвечает (она ведь очень быстрая).
На одном из таких проектов приложения тратили 30% cpu на нон-стоп запросы, когда работы не было
Apache Kafka: типовые проблемы и способы их решения