Я новичок в kafka, у меня есть требование, как у меня есть много серверов, которые производят огромное количество журналов, я хочу создать несколько производителей и потребителей. Я реализовал для одн
Я пишу потребителю, который вручную фиксирует смещение, как только серия записей будет отправлена в Mongo. В случае ошибки Mongo или любой другой ошибки предпринимается попытка перенести запись в сб
Мы используем версию Kafka 0.9 и имеем большое количество сообщений, помещенных в определенный раздел в теме kafka. И в этой теме есть несколько таких разделов. У нас есть один потребитель, назначенны