假设我们有一个 Kafka Sink 连接器从主题 TopicA 填充数据库，
还有一个 Kafka Stream 应用程序将更新推送到该 TopicA 主题。
我想知道是否：
Sink 连接器更新到数据库中的数据，以及
执行这些更新的时刻
受 Kafka Streams App 提交间隔的影响，如果是，如何影响？
【问题讨论】：
标签： apache-kafka apache-kafka-streams apache-kafka-connect
Kafka 生产者对 Kafka 消费者的提交间隔绝对没有影响。您只需要注意 Kafka 生产者不会比您的消费者更快，以避免消费者组滞后。如果消费者速度较慢，则可能会丢失数据。
【讨论】：
我会说它们确实是相关的。
如果 Streams 生产者线程更频繁地提交，那么数据会更快地到达主题，因此 Connect Sink 将更快地提取数据，最终对数据库调用更多查询。反之亦然，吞吐量较低。
但是，每个组件都可以单独调整。
【讨论】：
(task_id, status, error_message) 架构的任务主题。创建后，任务看起来像这样(task_id="xxx", status="processing", error_message="")。如果任务失败，则会发布类似这样的更新(task_id="xxx", status="done", error_message="bad error")。请注意，该主题已压缩。当我使用KTable 使用它时，一切正常。但是在我的数据库（Cassandra）中，有时它很好，有时我有这个(task_id="xxx", status="processing", error_message="bad error")。