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

Как документация функции GetMetaData: // GetMetadata queries broker for cluster and topic metadata....

Я использую confluent Kafka Go для моего проекта.При написании тестов из-за асинхронного характера...

Я использую библиотеку Confluent Kafka Go для своего приложения Golang.Я использую AdminClient

Я пытаюсь реализовать конвейер данных, который объединяет несколько неограниченных источников из...

В настоящее время я работаю над Apache Kafka, используя библиотеку go / golang. У меня есть...

Я реализую KStream-GlobalKTable-Join с использованием Spring-Cloud-Stream, и я столкнулся с...

Когда потребитель не получает сообщение в течение 5 минут (значение по умолчанию max.poll.interval

Я занимаюсь обогащением данных, присоединив kstream к ktable.Kstream содержит сообщения,...

ПРИМЕЧАНИЕ: НЕ ДУБЛИКАТ Как получить смещения групп потребителей для раздела в Golang Kafka 10 не...

Я хочу прочитать из темы __consumer_offsets с помощью этой библиотеки: https://github

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

Я создаю два файла docker-compose (главным образом потому, что мне не нужно постоянно перезапускать...

Я написал простую программу, которая имеет потребителя nodejs, потребляет данные от kafka, а затем...

У меня есть топология, которая выполняет два соединения kstream, проблема, с которой я сталкиваюсь,...

Я пытаюсь написать Kafka Consumer с GroupId foo, который подписывается на определенную тему и...

У меня есть топология Kafka Streams, в которой хранилище сеансов создается посредством агрегации...

Я никогда раньше не использовал кафку.У меня есть две тестовые программы Go, обращающиеся к...

Я использую конфлюэнт Голанг для моего клиента Kafka. Я использую AdminClient для создания /...

Я пытаюсь создать образ докера с помощью приложения go. Приложение (которое было разработано на...

Привет, я использую goka для потоковой обработки в go. Можно ли изменить имя темы таблицы при...

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

Пакет rdkafka не найден в пути поиска pkg-config. Пакет Confluent go выдает ошибку примерно так #...

У меня странное поведение с моим производителем и потребителем Кафки.Ниже приведены мои настройки...

Я использую потребитель с https://github.com/confluentinc/confluent-kafka-go. Версия kafka - 0.10.1