У меня есть пара пользователей Kafka, подписавшихся на тему, и мне нужно добавить несколько...

Я довольно новый в Кафке. Для проведения стресс-тестирования моего кластера и создания опыта...

Я новичок в Kafka и каким-то образом могу запускать kafka Avro для потребителей и производителей

Я использую https://github.com/Shopify/sarama для взаимодействия с Кафкой. У меня есть тема,...

Я использую Reactor Kafka , чтобы и потреблять, и генерировать события Кафки. В случае событий,...

У меня есть приложение, которое реализует API, как GET / themes / (строка: имя_позиции) /...

Я использую брокер сообщений Kafka для публикации и подписки на событие.Для этого используется...

Я создаю приложение Spring Boot с поддержкой Kafka.Я создал продюсера и потребителя, и все работает...

Я собираюсь реализовать чат-комнату, используя Spring boot и webSocket, а также Kafka, но мне нужно...

Вчера я обнаружил в журнале, что кафка повторно принимал некоторые сообщения после того, как...

У меня есть потребитель Java, который постоянно работает с большим количеством данных и сообщений .

Я использовал kafka для потоковой передачи своих сообщений, закодированных с помощью msgpack.После...

Я новичок в kafka, я пытаюсь использовать данные из kafka, используя python, который занимает 10...

Я пытался получить смещение, основанное на временной шкале, но когда я запускал свой код, он...

В моей теме кафки всего 10 записей / сообщений и 2 раздела по 5 сообщений в каждой. В моей группе...

Есть ли способ, как Кафка может рассчитывать на одного потребителя с несколькими темами? Вот мой...

2 производители создают сообщения подобного типа в однораздельной теме. Сообщения похожи по размеру...

Я изучаю способы разработки сканера в масштабе Google и, следовательно, изучаю возможное решение с...

Я пытался получить смещение из темы Kafka, основываясь на метке времени, когда я пытался запустить...

У меня один производитель и два потребителя с одним разделом.Я предпочел этот случай для обработки...

Может кто-нибудь посоветовать, может ли kafka-camel использовать сообщение из определенного раздела...

У меня есть потребитель kafka (написано на python).Он слушает темы с регулярным выражением (^. * _...

Я обновил свой kafka с версии 0.10.2.0 до версии 2.1.0, и теперь kafka не может принимать сообщения

У меня есть микросервис с несколькими конечными точками, и он также подключается к Kafka для...

Я хочу загрузить все записи из темы кафки, используя spark, но все примеры, которые я видел,...