Моя программа застряла в продукте.flush, и в центре управления слияниями нет соответствующего...
У меня есть карта между номером раздела и номером смещения данной темы в kafka. Я хотел бы...
Я застрял с проблемой, связанной с потребителем Kafka, использующим библиотеку python...
Мне бы хотелось иметь планировщик, который позволял бы мне создавать сообщения на темы AVRO через...
Я использую сливное облако для обработки очереди, я уже создал кластер и тему, и все работает...
Я пытаюсь подключить брокера Kafka с использованием "SASL_PLAINTEXT" или "PLAINTEXT" , но получаю...
У меня есть приложение pyspark, которое должно десериализовать слитые сообщения kafka avro в...
У меня проблемы с использованием Kafka в unity3d на Mac. Я выполнил шаги, описанные в решении,...
У нас работает конфлюэнтная кафка (https://github.com/confluentinc/cp-helm-charts) на kubernetes (1
Рассмотрим этот цикл событий: В то время как больше сообщений msg_in = consumer.Poll () msg_out =...
В течение последних нескольких дней я пытался ввести некоторые данные из Кафки в Друид, и до сих...
Я использую Apache Kafka в качестве обработчика сообщений и использую Confluent.Kafka в Asp.Net...
нетто и кафка. Я использую последнюю версию Kafka в .Net. Я пытаюсь написать код для batchproducer....
Я хочу совпасть с шаблоном подписки на канал kafka, в котором изменено предварительное исправление...
Я использую кластер Kafka из Bitnami в Azure (https://bitnami.com/stack/kafka/cloud/azure). Это...
У меня есть веб-приложение на основе Django, в котором я использую Kafka для обработки некоторых...
В моей локальной системе работает брокер kafka.Чтобы общаться с неработающими с помощью моего...
Как передать конкретное значение смещения, скажем, из 25-го смещения (возможно, из базы данных) в...
Я довольно новичок в Python и начинаю работать с Kafka.Итак, я настроил брокера Kafka и пытаюсь...
Я использую клиент Confluent's C # Kafka.Когда потребитель начинает потреблять, я наблюдаю с...
У меня проблема при использовании потребителя confluent-kafka с kerberos. У меня Kafka работает на...
Я создал тему в Kafka с 9 разделами, назвав ее «test», и собрал два простых приложения в C # (.NET...
Я установил Confluent CP Charts на GKE от ЗДЕСЬ Используя эти 2 команды, git clone https://github