apache-kafka-streams

0зной

2ответ

Как присоединиться к двум потокам Кафки, каждый из которых имеет несколько париваний?

У меня есть два потока Kafka, request и event, каждый из которых разбит на общее поле requestId (последние две цифры). Я хочу присоединиться к потокам и написать HDFS или местным filesystem? Как напис

8зной

1ответ

Динамическое подключение входного потока Kafka к нескольким выходным потокам

Есть ли встроенная функция в потоки Kafka, которая позволяет динамически подключать один входной поток к нескольким выходным потокам? KStream.branch позволяет разветвляться на основе истинных/ложных п

2зной

6ответ

Тестирование топологии Kafka Streams

Я ищу способ протестировать приложение Kafka Streams. Чтобы я мог определять входные события, а тестовый набор показывает мне результат. Возможно ли это без реальной настройки Kafka?

-3зной

1ответ

Есть ли шаблон CloudFormation для DC/OS, ElasticSearch, Kafka Connect и Kafka Streams?

Есть много примеров SMACK stack, но в моей инфраструктуре я хотел бы использовать ElasticSearch и Confluent Kafka Connect и Kafka Streams. Существует great tutorial on deploying a CloudFormation-based

0зной

1ответ

Поскольку Kafka Streams теперь доступен, Spark и Akka необходимы в стеке SMACK?

О том, чтобы опустить мои зубы в потоки Кафки с использованием технологии анализа данных IoT и увидеть множество примеров SMACK stack. Однако с Kafka Streams теперь доступно Spark и Akka действительно

1зной

2ответ

Кафка Струйные - все экземпляры местный магазин, указывающие на ту же тему

Мы имеем следующую задачу: Мы хотим слушать на определенную Кафки тему и построить это «история» - так что для указанного ключа экстракте некоторые данные, добавьте его к уже существующему списку для