Как я могу запустить приложение KafkaStream с Micronaut?

Question

Из https://micronaut -projects.github.io / micronaut-kafka / latest / guide / # kafkaStream , я вижу, что есть простой способ запустить приложение, которое запускает KStream.

Если я не хочу использовать KStream, но хочу использовать KafkaStream API с шаблоном топологии, это возможно с помощью Micronaut?

Answer 1

Да, конечно. Kafka streams - это клиентская библиотека, которую вы добавляете как зависимость и упаковываете вместе с вашим приложением. Это не зависит от того, как вы его развернете, вы должны учитывать количество представленных экземпляров / потоков, поскольку оно направлено на распределение нагрузки между экземплярами вашего приложения.

И просто, чтобы прояснить путаницу, Kafka Streams - это имя библиотеки, а KStream - это тип, который вы можете использовать в своем приложении, пожалуйста, проверьте пояснения по ссылкам ниже.

https://kafka.apache.org/22/documentation/streams/core-concepts

https://docs.confluent.io/current/streams/javadocs/index.html?org/apache/kafka/streams/kstream/package-summary.html