У нас есть трехузловой кластер Kafka, и я только что обнаружил, что журнал GC был настроен без...
В моем приложении KStreams три экземпляра выполняются как развертывание в кластере kubernetes....
У меня проблемы с использованием данного смещения с использованием python, в Java я реализовал...
У меня есть задание Spark Streaming, которое считывает данные из разделов kafka ( один исполнитель...
У меня есть тема apache kafka "historyTopic", связанная с потоком: KStream<Long, byte[]>...
Я пытаюсь работать с потоками Кафки и создал следующую топологию: KStream<String,...
У меня проблема с моим приложением. Код: KTable<Long, byte[]> table = stream.groupByKey()
Не удалось найти пакет lib Kafka 2.x для PHP.Я прошел по ссылкам ниже: 1) https://switchcaseblog
Мы запускаем кластер Kubernetes с Kafka 0.10.2.В кластере у нас есть набор из 10 реплик, работающих...
Я использую MySQL-коннектор Debezium (0.7.5) и пытаюсь понять, каков наилучший подход, если я хочу...
Мы используем пружинный поток облаков 2.0 & Kafka в качестве посредника сообщений. Мы внедрили...
Проблема Потребитель с определенным идентификатором группы подключается к брокеру, прослушивает...
KTable<Windowed<String>,Demo1> windowstream = dummy1 .groupByKey(Serialized
Мне нужно рассчитать среднее с потоками кафки.Продюсер производит с Avro, поэтому мне нужно...
Добавление конфигурации сжатия в Kafka Streams, аналогично этой ссылке : properties
Я пытался заставить этот код работать часами: val spark = SparkSession.builder()
В загрузочном приложении Spring я хочу подключиться к 2 различным серверам кафки одновременно.Я...
Мои данные имеют форму json с разделителями новой строки и выглядят так, как показано ниже.Я читаю...
Я закрываю KafkaStream, когда мне нужно, основываясь на определенном условии: Закрытие:...
Я хочу провести модульное тестирование агрегата Kafka Stream, и я совершенно не понимаю, какой...
Я пытаюсь отправить данные в разные темы на основе некоторой оценки.Я использую SPring CLoud...
У нас есть 3-узелный корпоративный кластер kafka (linux on-prem), и на одном узле запущена служба...
Я работал над приложением, основанным на API-интерфейсе java kafka-streams, цель которого -...
Я использую клиентский пакет confluent_kafka версии 0.11.5 и Python 3.6.6 для взаимодействия с...
У меня есть вопрос о Kafka Streams TopologyTestDriver (https://kafka.apache