kafka-consumer-api

2зной

1ответ

Ошибка при использовании адаптера канала Kafkamessagedriven

Я использую spring-integration kafka, чтобы поговорить с kafka. Ниже приведена конфигурация, которую я использовал для использования адаптера messagedrivenchannel. <!-- kafka MessageDriven Channel Ada

3зной

1ответ

Будет ли kafka создавать новый следящий элемент, если одна из его реплик будет отставать от коэффициента репликации

Ниже приведена информация о разделе раздела по теме xx_json_topic. Это кластер Kafka с тремя узлами. Все узлы вверх: Topic: xx_json_topic PartitionCount:4 ReplicationFactor:2 Configs: Topic: xx_json_

0зной

1ответ

Какой формат данных будет считаться самым быстрым для написания на Кафке?

У нас есть различные возможности в Kafka для записи на него данных, например: String format, Byte Array. Какие данные foramt считаются самыми быстрыми при написании на Kafka. Кроме того, kafka предост

10зной

4ответ

Список потребителей Кафки

Мне нужно узнать, как задать вопрос Кафке. Я знаю, что могу сделать это, используя сценарий kafka-topics.sh, включенный в каталог bin\. Как только у меня есть этот список, мне нужно, чтобы все потреби

7зной

1ответ

Можно ли создать тему kafka с динамическим количеством разделов?

Я использую kafka для потоковой передачи событий посещений страницы пользователями веб-сайта в службу аналитики. Каждое событие будет содержать следующие данные для потребителя: идентификатор пользова