connect动态连接器

axkjgtzd  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(458)

这就是《开发人员指南》中关于动态连接器的内容https://docs.confluent.io/current/connect/devguide.html#dynamic-连接器
并非所有连接器都有一组静态的分区,因此连接器实现还负责监视外部系统是否有任何可能需要重新配置的更改。例如,在jdbcsourceconnector示例中,连接器可能会为每个任务分配一组表。在创建新表时,它必须发现这个问题,以便通过更新配置将新表分配给其中一个任务。当它注意到需要重新配置的更改(或任务数量的更改)时,它会通知框架,框架会更新任何相应的任务
我不知道该怎么做。
连接器类(扩展org.apache.kafka.connect.source.sourceconnector)实现 taskConfigs(int) , start(Map<String,String>) , stop() , config() , version() 以及 taskClass() . 它没有一个 poll() 或类似的方法。
我是不是应该在这里面产生一个线索 start(Map<String,String>) 监控外部系统?
如果检测到更改,我如何“通知框架”。javasdk中是否有一些api调用可以实现这一点,或者这是否意味着我必须调用 stop() 然后 start() ?
谢谢。

g9icjywg

g9icjywg1#

我是不是应该在这里面产生一个线索 start(Map<String,String>) 监控外部系统?
是的,没错。
如何“通知框架”。
通过 requestTaskReconfiguration() sourceconnector上下文的方法。

相关问题