Я новичок в Кафке, используя Spring Boot, и я работаю в ProJet. Я хочу интегрировать в него Кафку,...

Я пытаюсь выяснить, есть ли способ использовать функцию транзакции Kafka для записи в две темы...

Я следую https://docs.confluent.io/current/kafka/authorization

У меня есть требование в моем проекте IoT, например, пользовательское Java-приложение под названием...

Я использую provider-perf-test.sh для тестирования производительности.Выходные метрические...

Я использую версию весенней загрузки 2.0.3-RELEASE.Это мой конфигурационный файл.Когда я запускаю...

Я новичок в Apache Storm и пытаюсь создать топологию в шторме, которую можно использовать для...

Я хочу установить Flink kafka продюсер semantic. EXACTLY_ONCE, я использую код scala следующим...

KAFKA Admin API имеет метод createAcls, который используется для создания списков ACL на основе...

Соединение с узлом 1 не может быть установлено после _consumer_offset-49, я не могу решить проблему...

В моей текущей конфигурации я использую: HdfsSinkConnector и класс разделителя:...

Я пришел, чтобы найти ответ на свой вопрос при использовании kafka. Я использую kafka version 2.1.0...

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

Мне нужно получить данные из очереди Kafka (заполненные моим сценарием) для каждой реплики в...

Kafka версия: kafka_2.1.1 (двоичная) Когда я включаю Kerberos, я следую официальным документам...

Я полностью приседаю на Kafka суше. Если я запускаю команду /cfintools/confluent-4.0

Должны ли мы обновить нашу клиентскую библиотеку Scala Kafka (в настоящее время 0.10.2), чтобы она...

У меня есть довольно простое приложение, которое состоит из потребителя Kafka, сидящего за...

У меня есть две службы ( serviceA и serviceB ), с двумя темами (topicIn, topicOut). Поток одного...

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

Согласно документации Kafka; Новый потребитель Java теперь поддерживает сердцебиение из фонового...

У меня есть простой счетчик слов Flink, который читает из темы Kafka и выводит свой результат в...

При обновлении с k8s 1.10, используя те же графики, до v1.12.x, zookeeper запускается, но kafka не...

У меня есть исходный соединитель, написанный на Java, работает в распределенном режиме с offset

Я пишу интеграционный тест с использованием spring-kaka-2.2.0 в приложении весенней загрузки, мне...