公開する方法継続リスナーとしてkafkaのコンシューマーサービス

Question

私はkafkaトピックのコンシューマーを作成したJavaプログラムを持っています。 whileループでConsumerによってトピックを継続的に聴く。 より良いデザインとスケーリングのためにループは良いアイデアではありません。カフカのトピックを継続的に消費できるスレッドを生成できるソリューションや例がありますか？

Answer 1

ご迷惑をおかけして申し訳ございません。私はこれを持っていますが、これをしたいと思います。そして、私は個人的には、 "リスナーサービスを公開する"のような概念を理解していません...

Springソリューションのようなものをお探しの場合は、特定のプロジェクトを参照してください。Spring for Apache Kafka 。

ここでSpring Integrationについて話している場合は、スプリングカフカリファレンスマニュアルの特定の章にご注意ください。