0
創建指定的複製因子的話題從卡夫卡的正式文件，但下面說，從4.7 Replication卡夫卡：是否有可能通過Java客戶端
你可以在一個主題按主題基礎上設置此複製因子
但是從其java客戶端的javadoc，我找不到任何API與createTopic與複製因素有關。它只能通過它提供的shell腳本來實現嗎？
A
回答
2
您可以使用AdminUtils.createTopic()方法從kafka.admin包 - https://github.com/apache/kafka/blob/97e61d4ae2feaf0551e75fa8cdd041f49f42a9a5/core/src/main/scala/kafka/admin/AdminUtils.scala#L409-L418
相關問題
- 1. 卡夫卡消費者 - Java客戶端
- 2. 卡夫卡客戶端API的問題
- 3. 是否有可能忽略卡夫卡消費者與某些客戶端版本？
- 4. 卡夫卡連接或卡夫卡客戶
- 5. 從客戶端使用卡夫卡超級用戶ACL
- 6. 如何從卡夫卡用卡夫卡流通過間隔
- 7. 客戶端的卡夫卡生產者如何工作？
- 8. 使用卡夫卡到兩個客戶端
- 9. 集裝箱卡夫卡客戶端產生的錯誤信息給主機服務器卡夫卡
- 10. 高級用戶未能在卡夫卡
- 11. 使用卡夫卡通過Observable（RxJava）
- 12. 是否可以使用PayPal REST API向卡客戶端收費？
- 13. 是否可以從Java客戶端通過網絡訪問ODBC？
- 14. 選項卡上的SSH客戶端是否有Atom包？
- 15. 檢查卡夫卡主題的存在，通過使用Java中
- 16. 通過Java API獲取和更新卡夫卡主題配置
- 17. 卡夫卡 - 性能測試
- 18. Github：是否有可能通過ssh下載主檔案（沒有git客戶端）
- 19. 可以通過互聯網使用卡夫卡嗎？
- 20. 卡夫卡是否支持安全通信？
- 21. 提升客戶端卡住
- 22. 什麼是delete.topic.enable卡夫卡
- 23. 使用駱駝卡夫卡時是否可以訪問卡夫卡分區的數量？
- 24. 是否有可能在斯卡拉
- 25. 是否有可能在斯卡拉
- 26. 是否有可能在斯卡拉
- 27. 卡夫卡的retention.ms沒有被卡夫卡0.10.2強制執行？
- 28. 從Kafka客戶端增加卡夫卡主題中的分區數量
- 29. 在卡夫卡接收器連接器上設置唯一的客戶端ID
- 30. 單一版本的卡夫卡經紀商的不同版本的客戶端
感謝，它看起來像斯卡拉客戶端可以做到這一點。但是從kafka文檔中，它說：「從0.8.2版本開始，我們鼓勵所有新開發使用新的Java生產者。」，所以我感興趣的是如果有相應的Java客戶端API可以做到這一點 –
我是擔心沒有用於創建主題的純Java API，但實際上您也可以使用Java中的'AdminUtils'。但代碼看起來有點醜陋。但有可能爲此編寫一個Java友好的包裝器 – serejja
謝謝，是否有像javadoc這樣的scala客戶端API文檔？或者我應該直接從源代碼中找到它們... –