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

У меня есть кластер Apache Kafka с 3-мя брокерами, и я хотел бы определить, когда кластер больше не...

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

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

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

Я пытаюсь опубликовать авро-сообщение, используя AvroProducer confluent-kafka-python, используя...

Я пытаюсь создать объект CachedSchemaRegistryClient, используя confluent-kafka python api.Но это...

Работа над проектом с использованием клиента .net confluent kafka, получение исключения при...

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

Я использую конфликтующий клиент C # для соединения с Kafka и пытаюсь создать API, который мог бы...

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

Я реализовал потребителя kafka как консольное приложение, используя BackgroundService в .NET Core 2

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

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

Я пытаюсь отправить файлы csv в тему Kafka с помощью AvroProducer.s Я читаю файл csv и циклически...

Это мой простой фрагмент кода, в котором я пытаюсь прочитать потребителя общей формы записи Avro:...

У нас есть несколько микро-сервисов, разработанных на языках c # и go.мы используем confluent-kafka...

У меня есть атмосфера кафки, где через некоторое время убивают потребителя. В поисках информации об...

Я создал потребительское приложение для темы Kafka, используя библиотеку confluent.kafka и c #. Мне...

Я использую конфлюентный реестр Kafka и схемы, и я не могу найти способ иметь собственное имя схемы...

Я тестирую Apache Kafka Producer с нативной реализацией java против confluent-kafka Python, чтобы...

Можно ли произвести вывод в тему Кафки и записать в хранилище состояний за одну транзакцию?Но не...

Данные из исходной системы - abc@abc.com # kafka-avro-console-customer --bootstrap-server...