Я хочу построить Потребитель очереди сообщений, который пока будет иметь только одну реализацию для...
Мы используем kafka версии 2.11-0.11.0.2 и zookeeper версии 3.3.6. И они работают на Ubuntu 16.0.4....
Есть интерфейс Java для Кафки: public interface ConsumerRebalanceListener Как реализовать этот...
Я пытался заставить входящий SubscribeableChannel и исходящий MessageChannel работать в моем...
На одной коробке Ubuntu 14.04 Я следовал той же конфигурации, что и http://dojoblog.dellemc
Как внедрить производителя и потребителя верблюжьей кафки, использующего брокеров кафки и имя...
Я бы хотел настроить брокера Kafka в Kubernetes. Я использую образ докера...
Здравствуйте, у меня возникла проблема при установке разъема эластичного поиска для Kafka. Я...
Мне трудно найти простые шаблоны для обработки исключений в теме кафки. Сценарий таков: у...
Как реализовать ConsumerRebalanceListener с использованием Scala? public class...
У меня есть тема kafka, значение там - формат avro, где схема хранится в реестре схемы. Теперь я...
Подходит ли kafka connect для случаев, когда скорость передачи сообщений очень низкая. Пример: для...
Мы используем Apache Kafka, а приложение использует Spring Kafka для взаимодействия. В настоящее...
Я загружаю ниже файл JSON с ./confluent load CRM_TEST -d /kafka/CRM_TEST.json затем происходит...
Я пытаюсь запустить kafka-connect-hdfs безуспешно. Я добавил следующую строку в .bash_profile и...
jar-файл jdbc для ibm db2 as400 находится по адресу: /confluent-4.1
Похоже, что самый популярный клиент .net для Kafka (https://github
Я пытаюсь представить метод Java через Scala (более подробно об оригинальном методе Java - он...
При сбросе потребительских смещений kafka до ранних значений некоторые разделы сохраняются со...
Возможно ли в Кафке ежедневно архивировать данные в какой-либо каталог? Также дайте мне знать,...
Я использую шаблон Spring Kafka для создания сообщений. И скорость, с которой он создает сообщения,...
Старая версия предполагает, что потребитель подключит zookeeper, а новая версия предлагает связать...
Нам нужно поделиться частью нашего реестра схем с другой компанией, и мы не хотим, чтобы они видели...
Так где же установка. 2 составных файла, скоро будет 4. Все не может жить в одном и том же...
Я написал одного потребителя Kafka (используя Spring Kafka), который читает из одной темы и...