Использование Admin Client для связи с Kafka в коде Java.мы можем сделать все операции CRUD по...

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

Я ищу ссылку, где можно найти простую программу для отправки SNMP-ловушки в тему Apache Kafka с...

Я использую коннектор debezium для захвата изменений из базы данных MySQL и перемещения его в Kafka

Я нахожусь в процессе настройки мониторинга для потребителей и брокеров кафки. Мониторинг серверных...

сценарий использования - это сохранение всего сообщения (которое является JSON) и ключа в виде...

Является ли ReplyingKafkaTemplate блокированием?Любая реактивная альтернатива?

Я пишу приложение на Angular, и я использовал в качестве руководства следующее руководство...

Исключением является ошибка отправки HTTP-запроса в конечную точку:...

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

Моя настройка среды разработки: Windows 10 Enterprise Edition, 16 ГБ ОЗУ, 2,81 ГГц, 64-битная ОС.Я...

Наша настройка kafka выглядит следующим образом: 30 разделов на тему 1 потребительский поток мы...

Все работает, если запустить простую работу с kafka to kafka без защиты Kerberos.Мне нужно сделать...

Я развернул Kafka, используя Helm и Minikube. Мне нужно собрать производителя в Scala для этого...

Я создал простой поток данных в весеннем облачном потоке, в котором http - источник, а kafka -...

Есть кое-что, что я пытаюсь понять о том, как Avro-сериализованные сообщения обрабатываются Kafka и...

Я нашел эту статью , когда работал над подсчетом производительности моего производителя. В ней Джей...

Я играю с Кафкой, пытаюсь справиться с этим.Одна из вещей, которую мы должны уметь делать - это...

У меня есть тема Кафки и один раздел. Когда я создаю потребителя, упускается упоминание группы .id....

Я создал преобразователь, который выполняет некоторые преобразования на ConnectRecord для...

При чтении исключительно сообщений из одного раздела, живущего в теме Kafka, где временные метки...

Я пишу производителя Kafka, использующего Python 3.6, версия клиента Python-kafka - 1.4.4. Версия...

Я тестирую аварийное переключение брокера KAFKA (2.11_2.1.0). У меня есть 3 узла: node0: broker

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

Как получить chunked-ответ от KSQL-сервера kafka в приложении весенней загрузки java? Когда я делаю...