1
我有一個java程序，我已經爲kafka主題撰寫了消費者。在不斷循環中由消費者持續傾聽主題。 爲了更好的設計和縮放，而循環不是好主意。有沒有什麼解決方案或例子可以產生可以持續使用卡夫卡主題的線程。如何將kafka的消費者服務作爲持續監聽者
A
回答
0
對不起，你的問題不清楚。請分享這樣的東西：我有這個，但想要這樣。我個人並不理解像「暴露監聽器服務」這樣的概念......
雖然如果您正在尋找類似Spring解決方案的東西，請查看關於此問題的特定項目 - Spring for Apache Kafka 。
如果我們在這裏談論的是Spring Integration，請注意，請參考春季卡夫卡參考手冊中的特定章節。
相關問題
- 1. Flask API作爲實時kafka消費者
- 2. Rails API - 作爲消費者的服務
- 3. kafka消費者上的AssertionError
- 4. RabbitMQ消費者作爲Windows服務
- 5. Kafka transactional生產者和消費者
- 6. clj-kafka - 消費者空
- 7. kafka消費者不消耗服務器中的記錄
- 8. KAFKA Java消費者不工作
- 9. Apache Kafka如何將消息發送給多個消費者組？
- 10. 來自kafka消費者的InstanceAlreadyExistsException
- 11. kafka-python消費者給出的錯誤
- 12. 僞裝Confluent .NET Kafka消費者
- 13. Kafka高級消費者error_code = 15
- 14. Apache kafka - 消費者延遲選項
- 15. Kafka：消費者羣體中的消費者可以共享數據嗎？
- 16. 如何在多個消費者閱讀相同的kafka消息
- 17. Mullti生產者單消費者執行者服務設計
- 18. KAFKA + FLINK 1.1.2消費者羣組不作爲例外
- 19. 主持一個WCF服務或讓消費者主持一個？
- 20. 對消費者的node-kafka pause（）方法。任何工作版本？
- 21. Kafka生產者/廣域網上的消費者？
- 22. ActiveMQ獲取從java監聽主題的消費者數量
- 23. 作爲消費者和提供商的IS4 webapi服務器
- 24. 將扭曲的消費者轉換爲服務
- 25. Java生產者 - 消費者：生產者不「通知（）」消費者
- 26. 如何在使用Semphores的生產者 - 消費者中消費？
- 27. 如何從生產者消費卡夫卡的消費者？
- 28. 生產者 - 消費者使用任務
- 29. Java端點 - perl消費者web服務
- 30. OAUTH 1.0a沒有消費者服務
我試圖根據您的輸入改進問題，如果您建議，我會嘗試再次即興創作，因爲我對卡夫卡空間有點新。 – Sankalp
太棒了！正如我回答你的那樣：閱讀Spring Kafka手冊和該庫。 KafkaListenerContainer爲你做的東西。它真的在while循環中輪詢Kafka主題，在它的特殊線程中。 –