Может кто-нибудь сказать, какая версия Camel-Kafka или других связанных jar-файлов имеет следующие...

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

Я пытаюсь написать производителя Kafka, используя librdkafka (c code library).Я не хочу, чтобы...

Trying to configure the Factory as below: private ConcurrentKafkaListenerContainerFactory<Integer...

У меня есть Java-класс pojo для сопоставления входящих данных с JavaObject, я относительно новичок...

У меня есть вопрос о SpecificAvroDeserializer, поскольку из-за имени класса я всегда предполагал,...

Как использовать стандартный инструмент kafka-avro-console-consumer с Kafka, работающим через...

Я работаю локально на OSX. Я использую Кафку и зоопарка в локальном режиме.Имеется в виду зоокейпер...

Команда Redis представляет новый тип данных Streams для Redis 5.0.Поскольку Streams с первого...

Я завязываю установить кластер кафки (Битнами) в GCP.Успешно удалось создать тему по этому вопросу,...

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

Я пытаюсь синхронизировать все таблицы, прочитанные из Sap в cassandra, используя kafka, вот моя...

Возможный дубликат Kafka - Этот сервер не является лидером для этого раздела темы , но нет ни...

Могу ли я создать потребителя кафки для чтения ФИКСИРОВАННОГО (скажем, 100) количества сообщений в...

У меня возникла небольшая проблема с попыткой PoC Hyperledger Fabric в среде AWS EC2. У меня...

У нас есть приложение Spring MVC (которое является SAP Hybris), в которое мы хотим интегрировать...

Что такое за и против при размещении данных сначала в Kafka, а затем в базе данных, или другим...

Шаги: cd /opt/kafka_2.11-0.9.0.0 bin/zookeeper-server-start.sh config/zookeeper.properties...

Это мой код: def saveToOpenTSDB(rows: Iterator[String], url: String) { val requestConfig:...

Я выполняю несколько тестовых сценариев восстановления после сбоев для Kafka connect , процесс...

Допустим, у меня есть тема с данными прогноза температуры, как показано ниже: 2018-10-25,Melbourne...

У меня есть следующий json по теме, которую соединитель JDBC публикует в...

Я разработал @KafkaListener, который также помечен интерфейсом ConsumerAwareRebalanceListener,...

Я пытаюсь получить последнее смещение от потребителя Кафки.Я делаю следующие 2 шага consumer

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