Можно ли написать потребительский cmd / batch-файл kafka для вывода данных в файл каждое окно

Я хотел бы прочитать все сообщения из темы Кафки в запланированный интервал для вычисления...

Я понимаю, что заказ на раздел гарантирован в Кафке.Но как это повлияет на раздел, если существует...

Я новичок в Kafka, я внедрил кластер KAFKA на 3 серверах, и на 3 серверах я использую потребителей,...

Я использую этот соединитель https://www.confluent.io/connector/sap-hana-connector/ это моя...

Мы серийно потребляем кафку.мы используем X-сообщения, помещаем их в MYSQL, а затем фиксируем их....

Я сейчас учусь о Kafka Java Java.Среди содержимого о Concumer я часто видел ConsumerRecords.Я хочу...

Мы бы хотели создать механизм повтора кафки для сбоев.Я видел, что многие представили способ иметь...

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

У меня есть 2 экземпляра ec2, один для брокера Kafka, а другой для потребителя Kafka.Могу ли я...

Я использую commit async с kafka (очевидно, без автоматической фиксации). К сожалению, я столкнулся...

У меня есть Spring Boot проект, который реализует Kafka.Приложение использует producer для создания...

Я ищу улучшения в коде scala kafka.Для уменьшения задержки, что я должен делать в потребителя и...

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

Я пытаюсь сделать простой поток производитель-потребитель по Kafka, используя node-rdkafka Я...

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

Существует ли какой-либо API для проверки доступности брокера кафки (или списка брокеров) с помощью...

Вариант использования: Получите данные из Kafka, а затем запишите в БД, которая связана с...

Мой самый большой вопрос заключается в том, что у нас в кафке есть концепция, называемая группа...

Я пишу продюсер кафки и мне нужна помощь в создании разделов. У меня есть группа и таблица...

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

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

Я использую для настройки bootstrap.servers в моих приложениях производителя / потребителя / потока...

У меня есть приложение Flink, которое использует FlinkKafkaConsumer. Я заинтересован в получении...

max.poll.records был недавно изменен на 500 в конфигурации потребителя kafka, но мне интересно, как...