Я хотел бы попросить дать некоторую информацию по следующему вопросу - я использую Consumer

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

Когда я тестирую, мой код выглядит следующим образом. .format("kafka")

Я получаю неожиданные результаты от запроса KSQL к KTable, который сам определяется темой Kafka....

Я пишу приложение Kafka Streams в Scala, и меня беспокоит потенциальная утечка памяти / общее...

Я пытаюсь понять, как управлять org.apache.kafka.common.errors.SerializationException в Spring...

Моя проблема в том, что я не могу напечатать данные, собранные с Kafka, потому что, когда я пытаюсь...

Я пытаюсь прочитать запрошенный номер сообщения kafka. Для нетранзакционных сообщений мы будем...

Я получаю исключение InterruptedException в методе Спарка rdd.collect(). Трассировка стека: java

Я читаю из потоковых данных (значения, разделенные запятыми), используя KafkaUtils

У меня есть служба, которая использует потоки кафки и имеет локальный магазин кафки. Я храню записи...

У меня есть несколько экземпляров MyApp, которые прослушивают другой раздел с помощью KTables...

Я пытаюсь работать со встроенным кодом Apache Spark с интеграцией Kafka для онлайн-кода k-средних с...

Я получаю это исключение при запуске задания на искру: Exception in thread "main" org

Ну, по сути, я пытаюсь транслировать видео с помощью vlc. Я передаю видео байты через сервер kafka...

Java: OpenJdk 11 Kafka: 2.2.0 Kafka streams lib: 2.3.0 Я пытаюсь развернуть свое приложение Kafka...

SimpleProd.java package com.kafka.msg.main; import java.util.Properties; import org.apache.kafka

У меня есть задание Spark, которое использует данные из защищенной темы Кафки. Это работает, когда...

Spark Streaming от Kafka с чувствительной к последовательности обработкой: обработка неточна, когда...

Я хочу использовать данные из потока Kafka и записать их в MySQL, используя Apache Beam....

Что я делаю не так, Моя программа потока kafka ниже выдает ошибку при потоковой передаче данных:...

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

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

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

Представьте себе ситуацию, когда у меня есть тема со многими статусами, каждый в другом журнале с...