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

Я использую версию kafka 0.11.0.2 на кластере с 3 брокерами и подключаю новый диск ко всем брокерам

Я использую соединитель JDBC для перемещения данных из MySQL в Kafka. Интересующие меня данные...

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

У меня есть сценарий использования, где я должен собирать пользовательские события и сохранять его...

Я пытаюсь игнорировать плохие сообщения в коннекторе приемника с опцией errors.tolerance: all

Я хочу записать данные из Kafka в базу данных MySQL. Я реализовал следующий код. kafkaConsumer

Потребительское приложение Kafka имеет серьезные задержки (недостаточно быстрое потребление событий...

Я оцениваю AWS Managed Service Kafka (MSK) и знаю, что в настоящее время он находится в режиме...

Любой параметр в Kafka Connect, чтобы указать, с какого раздела специально читать сообщения.По сути...

если у меня уже работает Kafka в локальной сети, Kafka Connect - это просто конфигурация поверх...

Если у нас есть кластер стретч-кафки из двух ДК с 6 брокерами и 5 зоокейтерами, разделенные по...

У меня есть 3-х узловый кафка и 3-х узловый кластер zookeeper.Каждая пара kafka и zookeeper...

Для чтения Avro данных из Kafka у нас есть AvroDeserializationSchema. Но как насчет письма?

Мы пытаемся настроить исходный соединитель от mqtt до Landoop Kafka (после того, как нам...

Мне нужно записать время, затраченное потребителем на весеннюю кафку.Так как метод kafkaListener...

Согласно документации Кафки, acks=0 : the producer does not wait for the broker response but simply...

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

Caused by: java.lang.ExceptionInInitializerError Caused by: org.apache.kafka.common.KafkaException:...

Я боролся с проблемой использования kafka connect и приемника S3. Первая структура: { Partition:...

У меня есть производитель кафки с 4 темами. Когда я загружаю CSV в соответствии с типом CSV, я...

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

Я настроил работу Flink, записывая некоторые сообщения в тему Кафки.В качестве раковины...

У меня есть KafkaConsumer, где регистрируется следующая ошибка Heartbeat thread failed due to...

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