Кафка многораздельного заказа

Мне известно, что в Kafka невозможно заказать несколько разделов и что порядок разделов гарантирован только для одного потребителя в группе (для одного разде...

Это прекрасно работает большую часть времени. Тем не менее, в семантике точно один раз; это не будет работать.

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

NoBrokersAvailable: ошибка NoBrokersAvailable-Kafka

Кафка: Изменить количество разделов для конкретной темы, используя Java

Я новичок в Kafka и работаю с новыми KafkaProducer и KafkaConsumer, версия: 0.9.0.1Есть ли способ в Java, чтобы изменить / обновить количество разделов для к...

Kafka 0.8.2.2 - Невозможно публиковать сообщения

Мы написали Java-клиент для публикации сообщения для Кафки. Код, как показано ниже

Понимание тем и разделов Кафки

Как настроить ведение журнала для производителей Kafka?

Я использую клиент-производитель Kafka, и у меня нет проекта log4j в моем проекте.При запуске программа печатает много журналов Kafka Debug, которые я действ...

Но увеличивает ли удаление, которое происходит в брокере Kafka, задержку между отправлением и получением сообщений? И если так, есть ли способ избежать этого?

ольно новичок в кафке, так что прости меня, если этот вопрос тривиален. У меня есть очень простая настройка для тестирования времени:Машина A -> пишет в т...

Kafka 0.9.0.1 Java Consumer застрял в awaitMetadataUpdate ()

Я пытаюсь заставить простого Kafka Consumer работать с использованием Java API v0.9.0.1. Сервер kafka, который я использую, является док-контейнером, также р...

Невозможно создать сообщение для kafka из службы, запущенной в Docker