Я пытаюсь заставить мой сервис перечитывать тему kafka с начала до конца при запуске для...
Я пытаюсь запустить пример кода Kafka в среде с поддержкой Unity, и по этой причине я создал...
Из приложения Node.js я пытаюсь подключиться к брокеру Apache Kafka с помощью клиента node-rdkafka....
Я использую librdkafka C API потребителя (в частности, rd_kafka_consumer_poll для чтения, и я...
У меня есть тема с одним разделом.У меня есть 2 разные группы потребителей.У каждой группы...
Я использую Confluent.kafka для моего c # издателя и потребительского приложения. Прежде чем...
У меня есть тестовое приложение в .NET, которое создает производителя kafka и отправляет несколько...
У меня есть образ контейнера докера, который выдает некоторые сообщения на тему kafka, которая...
Невозможно прочитать несколько URL-адресов из текстового файла для SSL Avro Producer...
Скажем, мы должны использовать confluent-kafka-dotnet , ProducerConfig получает массив адресов...
В базовой конфигурации Kafka .NET, например, такой: conf = new ConsumerConfig { GroupId =...
У нас есть простое развертывание kafka 1.1.0 в автономном режиме на нашей машине с Linux.В файле...
Я использую клиентский пакет confluent_kafka версии 0.11.5 и Python 3.6.6 для взаимодействия с...
Я использую клиент на основе RD Kafka C для приема / выдачи сообщений в Kafka Broker.Некоторое...
Пытался использовать функцию паузы и возобновления потребителя конфлюентной кафки, но не мог найти...
Confluent Kafka 5.0.0 был установлен на AWS EC2 с публичным IP, скажем, 54.XX.XX.XX Открыт порт...
Я использую Confluent Kafka DotNet lib для создания и создания тем: producer.ProduceAsync(topic,...
Я пытаюсь запустить приложение Flask, которое использует Confluent Kafka для отправки сообщений на...
При использовании сообщений с использованием библиотеки Confluent Kafka C # я хочу видеть новое...
Я пишу микросервисное приложение с использованием C # asp.net core 2.0, Kafka, CQRS и Confluent...
Итак, я пытаюсь написать скрипт, в котором данные поступают из базы данных, а затем публикуются в...
в конфигурации коннектора исходного кода Kafka Connect У меня есть "_comment":...
Я пытаюсь использовать хранилище состояний для дедупликации сообщений, полученных топологией...
Я пытаюсь провести простой тест, в котором я использую Kafka-connect и spark Я написал...
Когда я говорю, что это встроено, я имею в виду следующую тему: https://stackoverflow