我是Kafka Connect的新手，我不知道Kafka partition和Kafka connect partition的区别。它们是同一个概念吗？如果它们不是同一个概念，它们之间的关系是什么？
以下是Kafka连接分区的介绍文档：https://docs.confluent.io/platform/current/connect/devguide.html
我是Kafka Connect的新手，我不知道Kafka partition和Kafka connect partition的区别。它们是同一个概念吗？如果它们不是同一个概念，它们之间的关系是什么？
以下是Kafka连接分区的介绍文档：https://docs.confluent.io/platform/current/connect/devguide.html
1条答案
按热度按时间des4xlb01#
Kafka Connect没有分区，只有工作者和任务。所有任务都是围绕生产者和消费者API的 Package 器，这些API从主题分区读取和写入。文档中提到“流分区”，但实际上是“Kafka主题”
SourceRecord的JavaDoc解释了内部分区值的实际含义，“文件名、表名、或主题分区"，但值本身是任意的，并且依赖于连接器。