У меня есть полезная нагрузка json, которую я хочу отправить в качестве заголовка в Api...

Цель: - организовать сине-зеленое развертывание для конкретной службы весенней загрузки, которая...

Я использую kafka-console-consumer для изучения темы кафки. Периодически я получаю это сообщение об...

У меня есть схема avro: "fields" : [ { "name" : "errortime",...

Я следил за нашими брокерами Kafka и увидел, что размер нашего чистилища принес 6K - 10K. как...

Мне нужен соединитель раковины kafka, позволяющий пользователю сохранять содержимое темы в виде...

Вопрос В автономном кластере Flink, работающем на сервере, я разрабатываю потоковое задание Flink в...

Amazon S3 можно использовать в качестве приемника в кластере Kafka. Я хочу проверить, можно ли...

Мы используем kafka-python для подключения к нашим экземплярам Kafka. Чтобы получить доступ к этому...

В кластере Kafka, содержащем N брокеров, для Темы T относительно раздела производители публикуют...

Я запускаю приложение Spring Boot и набрал compile('org.springframework.kafka:spring-kafka:2.1

Я пытаюсь написать модульный тест для слушателя Kafka, который я разрабатываю с помощью Spring Boot...

Мой код реализован для записи данных Avro через сервер Schema_Registry в брокер Kafka. Локальный...

Я успешно использую простой пользовательский класс Partitioner, написанный на Java, для приемника...

У нас есть 3-х хостовый кластер Kafka. У нас есть 136 тем, каждая из которых имеет 100 разделов с...

Когда я пытаюсь запустить Kafka connect для эластичного поискового реактора, в автономном режиме я...

есть ли какой-либо клиент администратора Python kafka, который может создавать темы / удалять темы...

Как использовать образ confluent / cp-kafka в docker compose с экспозицией на localhost и имени...

Мы столкнулись с некоторыми проблемами и разным пониманием между командой разработчиков и командой...

Я понимаю, что существуют и другие способы очистки тем Kafka, помимо разрыва темы или установки...

Я тестирую инструмент производительности Producer для Kafka 1.1.0 против 3-х брокеров со...

ШАГ 1: Запустите производителя для создания образца данных ./bin/kafka-avro-console-producer \...

Что значит установить какую-то тему for compaction? Каковы плюсы / минусы, если это не сделано для...

В целях тестирования я пытаюсь создать кластер Kafka на локальном мини-кубе. Кластер должен быть...

Существуют ли какие-либо показатели брокера, которые мы можем использовать для мониторинга брокера...