Могут ли два параллельных процессора в топологии выполнять установку / загрузку в одном глобальном...
В одной задаче в потоковом приложении следующие два метода выполняются независимо (то есть, когда...
Я создал кластер kafka с 3 брокерами и следующими данными: Создано 3 темы, каждая с коэффициентом...
Как показано в Confluent docs при написании приложений PAPI , вы должны закрыть хранилища, которые...
У меня есть один узел кафка брокер и простое приложение потоков.Я создал 2 темы (topic1 и topic2)....
Не могли бы вы разрешить мои сомнения.Я смог получить поле из jsonObject...
Я собираю значения в потоке следующим образом: private KTable<String, StringAggregator>...
Мне нужно получить количество строк в хранилище, при этом хранилище поддерживается в низкоуровневых...
У меня есть инфраструктура AWS 1 Кластер Kafka на 3 док-контейнерах, работающий на ECS,...
Я пытаюсь создать простое потоковое приложение, которое читает сообщения журнала в формате json и...
Допустим, у нас есть экземпляр с конфигурацией, как указано ниже, и состояния, поддерживаемые в...
Я хотел знать, какие операции с состоянием или операции без сохранения состояния мне нужно...
В настоящее время я пытаюсь переместить мои приложения Kafka в кластер Docker.Я нахожусь на CentOS...
Недавно мы обновили Kafka до v1.1 и Confluent до v4.0. Но после обновления мы столкнулись с...
Я создаю приложение kafka streams с помощью spring-kafka для группировки записей по ключу и...
Из потока (k, v) я хочу вычислить поток (k, (v, f)), где f - частота появления данного ключа за...
Я хочу использовать Java KStream в Kafka, чтобы отфильтровать все те значения, которые превышают...
У меня есть приложение 2 Kafka Streams.Одно приложение прослушивает, скажем, topic1 и производит на...
Частично это продолжение Агрегирование по определенному разделу в потоках Apache Kafka Предположим,...
Если потоковое приложение с состоянием запускается с 6 потоками на одном узле, произойдет ли...
У меня есть тест, который по темпераменту оставляет открытый поток производителя с непрерывной...
Я использую Kafka Stream API для тестирования некоторых функций.У меня есть поток наподобие:...
По умолчанию хранилища состояния Kafka Streams «компактны».Можно ли установить «сжатие, удаление» с...
У меня простой вопрос, но я не могу понять, как добиться ниже, используя потоки Kafka в Java? Я...
Я запускаю приложение Kafka Streams в Docker-контейнере с помощью docker-compose.Тем не менее,...