Kafka 源连接器的 poll() 方法是否保证成功将消息发送到 Kafka?
Is a Kafka source connector's poll() method guaranteed to succeed sending the message to Kafka?
我了解到 poll() 方法包含从外部源获取数据的自定义代码。我可以假设一旦 poll() 方法成功 returns 一系列 SourceRecord 对象,就可以保证将它们写入 Kafka 吗?
换句话说,如果多次调用,我是否需要担心以能够返回同一组记录的方式实现任务?
可能存在网络异常,领导代理可能会在生产者发送和任何确认之前或之间掉线,所以不,不能保证在极端条件下。
我了解到 poll() 方法包含从外部源获取数据的自定义代码。我可以假设一旦 poll() 方法成功 returns 一系列 SourceRecord 对象,就可以保证将它们写入 Kafka 吗? 换句话说,如果多次调用,我是否需要担心以能够返回同一组记录的方式实现任务?
可能存在网络异常,领导代理可能会在生产者发送和任何确认之前或之间掉线,所以不,不能保证在极端条件下。