Какая разница между Кафкой broker-list и bootstrap servers

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

Мне нужно установить сериализатор пользовательских значений в KafkaTemplate Spring . Значение...

Хранит ли брокер Kafka метаданные, которые использует API производителя (например, какие разделы...

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

Я хотел понять связь между временем ожидания, присутствующим в методе poll (), и конфигурацией...

В моем приложении я создаю одного производителя и одного потребителя....

Я пытаюсь получить данные в друид от Кафки. Так выглядят данные в кафке....

Я вижу необычное поведение с PyKafka, клиентом, который я только недавно начал использовать. Ошибка...

Я установил Kafka 1.1.0 с Zookeeper 3.4.12 в подсистеме Windows для Linux на моем ноутбуке с...

У меня установлена ​​kafka, которая работает нормально по ссылке: Digital Ocean Tutorial Я хочу...

Я не могу загрузить () строковый JSON в допустимый JSON, используя json.dumps().Вот код и результат

Я использую следующие jmx метрики для kafka connect.

Я хочу применить функцию кодирования меток sklearn.preprocessing для потоковой передачи данных с...

у нас есть кластер hadoop версии 2.6.4 с графическим интерфейсом ambari в нашем кластере, у нас...

Как получить thread_id текущих изменений в БД, выполненных через сервис весенней загрузки. Я...

Я использую настройку hyperledger fabric 1.1.Все сервисы упакованы в рой докеров.Я пытаюсь...

Как мы можем проверить, например, сколько потоков поддерживается кластером Kafka с 3 узлами Мой...

Мне нужна помощь в настройке докер-контейнеров моего kafka brokers для структуры hyperledger. Моя...

Как создать Kafka AdminClientConfig (Kafka JAVA Admin api) с доверенным хранилищем и паролем....

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

Я пытаюсь найти исходный код, и все, что я могу найти, это /Users/myUser/

Можно ли прочитать одно сообщение из компактной темы Kafka, если я знаю ключ сообщения? Я не нашел...

Я пытаюсь уменьшить трафик к нашему постоянному уровню, объединяя обновления с теми же ключами

Я хотел бы удалить все пустые темы Кафки (периодически из cron). Мне не удалось найти одну команду...