Я нахожу alterConfigs в KafkaAdminClient, поэтому я хочу установить лимиты квот через...

Какое свойство производителя Kafka использовать для достижения следующих целей? Я использую UDP...

Я супер новый для Кафки. Я установил kafka и zookeeper с помощью homebrew на моем Mac, и я играю с...

Допустим, у меня есть два продюсера (ProducerA и ProducerB), пишущие на одну и ту же тему с одним...

У меня есть трехузловой кластер Confluent Kafka. На каждом узле запущены Zookeeper, Kafka Broker,...

Кажется хорошей практикой запустить Kafka MirrorMaker в целевом кластере. Я не могу найти причины...

Будет ли какое-либо влияние на производительность kafka при изменении экземпляра group.id...

Есть ли способ создать сообщение в kafka-console-produser с нулевым значением (т. Е. Пометить его,...

Представим себе поток сообщений в разделе кафки. 1, 2, 3, 4, 5 Есть ли способ для потребителя...

Прямо сейчас мой производитель kafka отправляет все сообщения в один раздел темы kafka, который на...

Я использую org.apache.kafka.clients.consumer.KafkaConsumer в своем приложении для обработки...

У меня есть один фреймворк, использующий Spring Boot, который содержит контроллер RestController...

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

Для использования AdminClient мне нужно импортировать: org.apache.kafka.clients.admin.AdminClient...

Я нахожу эту строку в своем комментарии: «Интерфейс обратного вызова квоты для брокеров, который...

Когда у меня 1000 веб-сервера и все интересуются сообщениями из темы. Я думаю о записи определенных...

После обновления до Spring Cloud Stream Elmhurst.RELEASE метод @StreamListener выдает ошибку при...

Я не могу найти информацию о том, как Kafka справится с ситуацией, когда у сжатого в журнале...

Итак, я написал простую программу kafka, которая отправляет сообщение производителю, но когда я...

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

У меня есть метод @StreamListener, где он будет выполнять вызов REST. Когда вызов REST возвращает...

Мы получаем это в тесте и продукт. Это непрерывно, и мы не знаем, как эти ошибки продолжают...

Я определил схему в реестре схем с 10 полями. Использование confluent-3.3.0 , Кафка 0.10...

Мы сталкиваемся с проблемой с нашей настройкой kafka, поскольку видим, что наши узлы Kafka...

Состояние задачи соединителя сбой с ошибкой: org.apache.kafka.connect.errors.ConnectException: java