Я использую преобразование Avro Value, которое генерирует схему, подобную приведенной ниже (это...

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

Я тестирую скорость сжатия kafka по темам, но получаю некоторые странные результаты, ZSTD в 5 раз...

Я изменил docker-stack.ymll конфиг из этого github проекта: version: '3.1' volumes:...

У меня есть игрушка Flink, которая читает 3 темы кафки, а затем объединяет все эти 3 потока.Вот и...

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

Я отправляю входные данные JSON в тему Кафки. Я могу увидеть те же данные JSON в kafka при помощи...

Я провожу некоторые тесты с apache kafka, обе версии 1.1.1 и 2.1.1 имеют такое же абсурдное...

Я пытаюсь прочитать последнюю запись раздела темы.Производитель темы пишет транзакционно

Я запускаю интеграционные тесты для других вещей, кроме kafka (db и т. Д.), Но из-за того, что в...

Я новичок в kafka и пытаюсь создать простое приложение hello world, используя ссылку tutorial .Я...

Я опубликовал несколько CNCF CloudEvents на Kafka Broker. Я пытаюсь просмотреть их непосредственно...

После создания объектов Connector и SourceTask в Kafka с Java я не могу понять, что можно сделать с...

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

Я использую экземпляр Google Cloud Kafka для подключения к сервису загрузки Spring в облачном...

Я использую Scala 2.12 и мне требуются библиотеки для преобразования сообщений в Avro (необходимо...

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

Я использую пакет nuget Kafka-Net, чтобы сделать базовый POC для производства и потребления Kafka....

У меня есть тема Kafka, из которой мне нужно читать данные JSON с помощью потребителя, но на основе...

У меня есть Kafka Connect S3 Sink, пишущий записи в Amazon S3. Этот конкретный приемник пишет о 4k...

У нас есть проблемы с производительностью среди наших потребителей.Точнее, в ЧТО это делается с...

Я использую небольшой вариант примера кода опроса клиента, который я нашел в Confluent github : c =...

Это мой server.properties: listeners=PLAINTEXT://localhost:9092,SSl://localhost:9093 ssl.client

Я читаю 500 МБ случайных кортежей от производителя Kafka непрерывно, и в топологии шторма я...

Я новичок в kafka и прошел документацию , но ничего не понял.Может кто-нибудь объяснить, когда...