Мой потребительский процесс умер при удалении темы.Но программа просто заблокирована и выводит логи...

Spark (2.3) Пакетное задание, подключающееся к Kafka (аутентификация SASL-Kerberos) для...

Попытка разработки приложения Spring Cloud с использованием kafka Конфигурация, используемая для...

У меня проблемы с работой центра управления.Настроил 3-х узловый кластер kafka, используя следующий...

Я работаю с Apache Spark 2.3 и читаю данные с порта UDP в формате lz0, распаковываю эти данные в...

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

Я пытаюсь записать фрейм данных, который содержит около 230 миллионов записей для Кафки.В частности...

У меня есть вопрос о TimeWindows с Kafka Streams, некоторые концепции меня действительно смущают. У...

Я знаю, используя API-интерфейсы потребителей Kafka, мы можем получить смещение, соответствующее...

У меня сложная топология, включающая в себя KStreams, KTables, объединения, повторное использование...

У меня проблемы с объединением двух потоков кафки, извлекающих дату из полей моего события

Я пытаюсь запустить новый проект SBT Scala и получить в файле build.sbt следующее: name :=...

У меня есть тестовое приложение в .NET, которое создает производителя kafka и отправляет несколько...

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

Я создал шаблон scala g8 для kafka streams, но заметил, что он печатается только когда приложение...

Мой senario выглядит следующим образом: Kafka ----> spark stream (server1) -----> spark stream...

Я пытаюсь интегрировать Spark с Kafka с Python.У меня есть тема под названием mawstopic, которая...

У меня есть несколько авромасел и соответствующие структуры codec_traits .Я использую libserdes +...

У меня есть продюсер, пишущий в тему Kafka с 100 разделами, и он выбирает раздел по идентификатору...

В приложении Kafka Streams у нас есть KTable (не KStream), в котором мы хотим вычислить некоторую...

У меня есть образ контейнера докера, который выдает некоторые сообщения на тему kafka, которая...

Надеюсь, что кто-то может помочь мне здесь, У меня есть поток данных, который мне нужно связать...

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

Информация, которую я ищу, - это HostInfo экземпляра streams, в котором хранится сохраненный ключ,...

Я использую auto.offset.reset=earliest в своем коде и использовал коммит смещения в kafka с помощью...