apache-kafka-streams

0зной

1ответ

Редактирование правил в реальном времени и KafkaStreams

У меня есть требование разрешить пользователям «бизнеса» создавать и редактировать правила для данных, поступающих из входных потоков. Правила должны быть дружественными к бизнесу, и не может быть ник

4зной

1ответ

Почему Apache Kafka Streams использует RocksDB, и если можно изменить его?

Во время исследования в новых функциях Apache Kafka 0.9 и 0.10, мы использовали KStreams и KTables. Существует интересный факт: , что Kafka использует RocksDB внутренне. См. Introducing Kafka Streams:

0зной

1ответ

Совокупные поток данных с Кафкой Streams

Я получение сообщения в Кафку с кодом вроде этого: Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); props.put("retries", 0); props.p

1зной

1ответ

Как добавить пользовательский StateStore в процессор DSL Kafka Streams?

Для одного из моих приложений Kafka streams мне необходимо использовать функции как DSL, так и API-интерфейса процессора. Мой потоковый поток приложений: source -> selectKey -> filter -> aggregate (on

5зной

2ответ

Является ли Kafka Stream StateStore глобальным во всех случаях или только локально?

В примере Кафки WordCount используется StateStore для хранения подсчетов слов. Если в одной и той же группе пользователей есть несколько экземпляров, StateStore является глобальным для группы или явля

3зной

1ответ

Kafka Stream от JSON до Avro

Я пытаюсь использовать поток Kafka для преобразования темы с сообщениями String/JSON в другую тему как сообщения Avro. поток Основной метод: streamsConfiguration.put(StreamsConfig.KEY_SERDE_CLASS_CONF

0зной

1ответ

AdminUtils.createTopic API throws kafka.admin.AdminOperationException

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

3зной

1ответ

Kafka Streams "map-side" присоединиться к поиску словаря

Этот вопрос является продолжением Kafka Streams with lookup data on HDFS. Мне нужно присоединиться (например, «присоединиться к карте») данные небольшого словаря к основному потоку Кафки AFAIK, экземп

2зной

1ответ

kafka new api 0.10 не предоставляет список потоков и потребительских объектов по одной теме

Раньше я использовал 0.8 API. Когда вы передаете ему список тем, он возвращает карту потоков (по одной записи для каждой темы). Это позволяет мне создавать отдельный поток и назначать поток каждой тем