У меня довольно простой потребитель Кафки: MessageListener<String, T> messageListener =...

Сегодня у нас была проблема, когда потребитель Kakfa не смог подключиться ни к одному брокеру, и в...

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

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

У меня есть слитная настройка kafka и docker-compose.yml файл https://github

Микросервис1 -> Кафка -> Микросервис2 Как передать идентификатор трассировки при передаче данных? и...

Я пытаюсь запустить реестр схемы и вижу следующее исключение. ERROR Server died unexpectedly: (io

Я реализовал топологию цапли, которая читает сообщения из очереди Кафки. Следовательно, моя...

Я экспериментировал с Apache Kafka, платформой распределенного потокового вещания, но у меня...

У меня есть поток kafka-connect из mongodb-> kafka connect- >asticsearch, отправляющий данные от...

Я ищу распределенную систему очередей, которая поддерживает отложенную доставку сообщений, т. Е....

В настоящее время я изучаю kafka и новые, я пытаюсь запустить kafka-server-start.sh config/server

У меня есть поток данных в мои темы с сервера датчиков, который я не могу контролировать. В теме A...

Я хочу настроить kafka-manager от Yahoo. При запуске с этой командой: ./sbt clean dist. Я получаю...

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

Я создаю потребителя Kafka для моего проекта .net. Я использую kafka-net (нативный клиент c # для...

Я внедряю и поток интеграции dsl spring, который принимает сообщения от Kafka Фрагмент кода: return...

Привет: я новичок в kafka, и я выполнил следующие шаги для установки и инициализации kafka на моем...

Мы хотим предложить следующее, основываясь на наших проблемах с дисками kafka Каждый кластер...

Я пытаюсь создать данные в targetTopic1 на основе sourceTopic1 и sourceTopic2. Обе исходные темы...

Если каталог не содержит данных темы Kafka, он не должен существовать в каталоге журнала Kafka...

Я учу кафку с простым потребителем. Я настроил неправильный URL сервера. При использовании метода...

Мы используем Kafka с Spring Cloud Stream, и нам нужно подключиться к реестру Confluent Schema в...

Я нашел свойство auto.offset.reset = самое раннее или auto.offset.reset = самое последнее. Теперь...

Я пытался заставить kafka-docker работать уже несколько дней, и я не знаю, что я делаю неправильно....