java-Kafka JDBC鏈接器中的自定義分區分配

我有一個用例,其中我須要根據消息中的某些關鍵參數編寫自定義邏輯來分配分區.我對此進行了一些研究,發現kafka轉換支持重寫Transformation接口中的某些方法,可是我沒法在git hub或其餘地方執行一些示例代碼.有人能夠共享示例代碼或git hub連接在kafka JDBC源鏈接器中進行自定義分區分配嗎？git   提早致謝！.apache 最佳答案app Kafka默認使用如下方法分配

>>阅读原文<<