Я никогда раньше не использовал кафку.У меня есть две тестовые программы Go, обращающиеся к...
Я использую конфлюэнт Голанг для моего клиента Kafka. Я использую AdminClient для создания /...
У меня вопрос о том, как мы можем интегрировать производителя kafka с интерфейсным веб-приложением....
Невозможно записать сообщение в тему kafka (продюсер) при вызове kakfa производить класс с циклом....
Я пытаюсь отправлять сообщения MQTT на разные темы с помощью Kafka. Я использую Confluent...
Мне нужно очистить или удалить темы Kafka программно, используя язык C #.В настоящее время я...
Я работаю над потоковой передачей своей веб-камеры потребителю kakfa, чтобы провести некоторый...
Этот скрипт - метод подписки на событие от Kafka. using Confluent.Kafka; using Confluent.Kafka
У меня есть приложение на стороне сервера, написанное на Go, которое создает события Kafka.Он...
Мы наблюдаем огромные утечки памяти при использовании Kafka с использованием библиотеки Confluent...
Я пытаюсь понять Avro Serialization на Confluent Kafka вместе с использованием реестра Schema.До...
Пакет rdkafka не найден в пути поиска pkg-config. Пакет Confluent go выдает ошибку примерно так #...
У меня странное поведение с моим производителем и потребителем Кафки.Ниже приведены мои настройки...
Я использую потребитель с https://github.com/confluentinc/confluent-kafka-go. Версия kafka - 0.10.1
У нас есть потребитель Kafka, который будет читать сообщения и делать подобные вещи, а затем снова...
Я новичок и вижу один пример с одним потребителем в репозитории github ниже, но есть ли идеи, как...
var msgs = new List<string> {“msg1”, “msg2”, “msg3”}; var tasks = new List<Task>();...
У меня сейчас проблема с кодом, который я написал для Кафки.Код довольно прост, источник производит...
Следующее исключение выдается для Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR...
Я планирую использовать KSQL для потоковой обработки. У меня есть следующие требования. Как только...
есть ли какой-либо клиент администратора Python kafka, который может создавать темы / удалять темы...
У меня есть необработанные потоки из 3 таблиц mysql, 1 основной и двух дочерних таблиц. Я попытался...