Я использую kafka-streams для объединения сообщений в KTable. Внутри моей логики агрегации я всегда...

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

мой вопрос о потоках Kafka Ktable.groupBy.aggregate. и результирующие агрегированные значения....

У меня есть приложение kafka streams, использующее тему kafka. Он только потребляет и обрабатывает...

пытается понять, как использовать инструмент сброса для приложения kafka stream. Однако я смущен...

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

Я использую Spring Cloud Stream с брокером сообщений Kafka в моем Java-приложении. Я использую...

У меня есть приложение Kafka Streams, которое использует тему «А» с 10 разделами и примерно 10 000...

У нас есть приложение Kafka Streams, которое испытывает странное поведение. Случайно, когда задание...

У меня есть топология KStream, где мы используем неперекрывающиеся окна. .groupBy((userId, brandId)...

Я застрял в потоках kafka и не могу справиться со сценарием с DSL. Может кто-нибудь, пожалуйста,...

У меня есть приложение Java Kafka, которое использует тему. Иногда встречается ошибка...

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

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

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

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

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

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

Я бы хотел прочитать в облачном потоке список тем (входящих). Идея состоит в том, чтобы сканировать...

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

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

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

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

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