Вопросы с тегом apache--kafka-потоки

1 голос

1 ответ

Доступ к ProcessContext :: forward из нескольких пользовательских потоков

Dima Svider / 09 февраля 2020

2 голосов

1 ответ

Понимание количества созданных экземпляров StreamProcessor и совместное использование потоковой задачи одного и того же экземпляра streamprocessor?

CuriousMind / 09 февраля 2020

1 голос

1 ответ

Являются ли хранилища Kafka Streams State Store подходящим решением для приложений с сохранением состояния, работающих с большими объемами ключей и данных?

codependent / 08 февраля 2020

1 голос

1 ответ

Кафки потоки + как истечь записи в хранилище состояний асинхронно

user12294404 / 08 февраля 2020

0 голосов

2 ответов

Открывать и закрывать канал в клиенте gRP C при каждом запросе

Alex P. / 06 февраля 2020

0 голосов

1 ответ

Kafka Streams с одним разделом, чтобы сделать паузу при ошибке

Nikhil K / 06 февраля 2020

0 голосов

0 ответов

Kafka Streams: Может кто-нибудь указать мне на полностью реализованный java пример отправки сообщений в тему DLQ (Dead Letter Queue)

prixa / 05 февраля 2020

1 голос

1 ответ

Найти первое событие в Kafka KStream

Vipul Goyal / 05 февраля 2020

0 голосов

0 ответов

Потоки Кафки - невозможно получить хранилище состояний, потому что поток потока НАЧИНАЕТСЯ, а не РАБОТАЕТ

Tim Cranfield / 05 февраля 2020

1 голос

1 ответ

Можно ли запустить 2 JVM Kafka Streams с одинаковым идентификатором приложения, но разными топологиями?

Guruguha Marur Sreenivasa / 05 февраля 2020

1 голос

1 ответ

Kafka-Streams: агрегирование по результату соединения (KTable, KTable)

styx / 04 февраля 2020

3 голосов

2 ответов

Потоки Кафки объединяют несвязанные потоки

cudba / 04 февраля 2020

0 голосов

1 ответ

Kafka Streams - RocksDB - максимальное количество открытых файлов

Raman / 03 февраля 2020

2 голосов

1 ответ

Custom Partitioner для простого производителя | Потоки Кафки

Alpcan Yıldız / 03 февраля 2020

0 голосов

1 ответ

Kafka Stream - только один экземпляр читает из разделов

Ron Shimoni / 03 февраля 2020

0 голосов

1 ответ

Будут ли несколько экземпляров приложений Kstreams обрабатывать данные с состоянием, если перераспределенный ключ не совпадает с ключом хранилища состояний?

0x SLC / 31 января 2020

0 голосов

1 ответ

Потоки Кафки - подавить до конца окна (не закрыть)

Sören Henning / 31 января 2020

0 голосов

1 ответ

Как использовать разные serdes для разных процессоров в Kafka Streams?

JavaTechnical / 30 января 2020

1 голос

0 ответов

Потоки Кафки, настраиваемый ключ-время c time-window

Igor Piddubnyi / 30 января 2020

0 голосов

0 ответов

Приложения Kafka Streams перезагружаются из-за ошибки с кодом Kubernetes 137

Rahul Kumar Dhamu / 30 января 2020

0 голосов

1 ответ

Spring Cloud Stream - запрос topi c без явного использования KTable / KStream?

Boon / 27 января 2020

0 голосов

1 ответ

Кафка Потоки, как преобразовать объект в два объекта, и они используют один объект в качестве ключа, а другой в качестве значения для groupBy

BryceSoker / 27 января 2020

0 голосов

1 ответ

Как получить две темы с одним и тем же ключом раздела и количеством разделов, принадлежащих одному и тому же потребителю в приложении kafka streams

Rohit / 27 января 2020

0 голосов

1 ответ

Агрегирование (суммирование) количества событий из разных тем Кафки

codependent / 27 января 2020

1 голос

1 ответ

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

Anwesh Valleshetti / 26 января 2020