apache-kafka-streams

11зной

1ответ

Как отправить итоговый результат агрегации кафки-потоков из окна с заданным временем KTable?

Что я хотел бы сделать это: Потребляйте записи из темы номера (Лонг) Совокупных (COUNT) значения для каждого окна 5 сек Отправить конечный результат агрегации в другая тема Мой код выглядит следующим

3зной

1ответ

kafkastreams - добавление дополнительной вычислительной мощности

Im работает над POC-преобразованием существующего Flink применение/топология для использования KafkaStreams. Мой вопрос о развертывании. В частности - в Flink добавляется «Рабочие узлы» к установке fl

4зной

2ответ

Остановить приложение Kafka Streams

Возможно ли иметь приложение Kafka Streams, которое проходит через все данные в теме и затем выходит? Пример: Я делаю данные по темам, основанным на дате. Потребитель получает начало cron, пробегает в

1зной

1ответ

Периодический NPE в потоке процессора Kafka Streams

Использование kafka-streams 0.10.0.0, я периодически вижу исключение нулевого указателя в StreamTask при пересылке сообщения. Он варьируется от 10% до 50% вызовов. NPE происходит в этом методе: public

0зной

1ответ

Удалить неиспользованную группу потребителей kafka

Я использую Confluent/Apache Kafka 0.10 с уплотненной темой как механизм синхронизации распределенного кеша. Когда приложение запускается, он генерирует идентификатор группы конкретных экземпляров. По

0зной

1ответ

Объединение двух результатов Кафка KTable в NullPointer в RocksDB

Я пытаюсь соединить два Кафка потока DSL KTable с помощью: KTable<String, String> source = builder.table("stream-source"); KTable<String, String> target = builder.table("stream-target"); source.join

2зной

2ответ

Сброс сброса потока Kafka в ноль для группы потребителей

Я написал приложение Kafka Streaming, которое просто фильтрует строки на основе некоторого состояния и загружает его в MongoDB. Процесс потоковой передачи работает нормально, но из-за некоторой ошибки