apache-kafka

0зной

1ответ

Потребность в потребительской корзине Kafka, полученная в пакете

Я искал у потребителя партии Kafka, и я не нашел ценной информации. использования: Производитель будет производить данные очень часто и на потребительском сайте мы будем использовать данные и от потре

1зной

1ответ

Является ли mapWithState/updateStateByKey кэшем?

Предположим, у меня есть приложение, создать новый поток из Кафки У некоторых преобразований Использование mapWithState/updateStateByKey для сохранения состояния. Сделайте еще несколько преобразований

1зной

1ответ

Многопоточный потребитель или потребительский продукт Kafka

Какой должен быть лучший подход при внедрении потребителя кафки. Задача считывается с Kafka и записывается обратно в db. Миллионы рядов Подход 1: За раздел - для потребителя - Подождите, пока сообщени

0зной

1ответ

Kafka Consumer Cluster Environment Offset

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

3зной

1ответ

Почему распределенный соединитель Kafka умирает, когда узел, который я создал, убит?

Я запускаю соединитель Kafka в распределенном режиме в локальном контейнере Docker «запуск» (отдельно от контейнера узла Kafka). Коннектор работает так, как ожидалось, но когда я убиваю контейнер запу

1зной

3ответ

Проверьте наличие сообщения в теме Kafka

Я хочу избежать отправки повторяющихся сообщений в тему Kafka. Каков идеальный способ его достижения? Использование Java-клиент для Apache Кафки, есть в любом случае, чтобы проверить, существует ли со