【Kafka】kafka動態獲取某個topic的partition信息

現在有這樣一種場景,系統啓動前,預期abc topic創建了一個100個分區,大概用個一段時間,之後可能會動態新增分區數,這就要求生產者在生產數據時,能夠動態實時的獲取分區數,做到及時有效的哈希生效,讓數據進入新增的分區,kafka的jar包裏倒是有這麼一個api可以做到,不過這種場景本人覺得還不如夜裏做一次升級呢。 畢竟在生產數據時每次獲取abc topic的分區信息是一個性能損耗,一天生產10
相關文章
相關標籤/搜索