java-Kafka JDBC链接器中的自定义分区分配

我有一个用例,其中我须要根据消息中的某些关键参数编写自定义逻辑来分配分区.我对此进行了一些研究,发现kafka转换支持重写Transformation接口中的某些方法,可是我没法在git hub或其余地方执行一些示例代码.有人能够共享示例代码或git hub连接在kafka JDBC源链接器中进行自定义分区分配吗？git   提早致谢！.apache 最佳答案app Kafka默认使用如下方法分配

>>阅读原文<<