Мне нужно рассчитать среднее с потоками кафки.Продюсер производит с Avro, поэтому мне нужно...

Я хочу создать простое приложение, основанное на данных датчика, с Apache Kafka. Мой вопрос очень...

У меня есть приложение Kafka Streams, работающее на нескольких JVM (всего 5) для повышения...

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

Краткое объяснение того, чего я хочу достичь: я хочу сделать функциональные тесты для топологии...

Сценарий: У меня есть приложение KafkaStreams с полным хранением.У него есть одна тема событий и...

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

Я передаю данные в режиме реального времени от Кафки.Но данные в формате Avro.Невозможно...

Когда поле типа Timestamp имеет значение null, сериализация завершается неудачно (трассировка и...

С Kafka Stream я всегда инициализирую свой магазин из ссылочных компактных тем, используя этот код:...

Я хотел бы иметь семантику "Точно один раз", но я не хочу читать сообщения с помощью Consumer.Я бы...

Я выполнил операции объединения двух kstream, которые состоят из данных формата avro, а затем мой...

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

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