Kafka Source
下文介绍在向导模式中使用Kafka作为数据源的采集配置逻辑。
配置项操作和解释
操作页面:
- 参数解释
配置项 | 说明 |
---|---|
Topic | 选择需要采集的Topic |
读取类型 | 支持Json、Text格式 |
Offset | Offset解释:消费者消费完了消息是不会被立刻删除的,每个消费者把消费的数据消费到哪里了就需要做个记录,就是offset。 在采集时,我们就需要指定从哪个offset开始消费。目前支持:group、latest、earliest、指定时间、自定义偏移量。 |
下文介绍在向导模式中使用Kafka作为数据源的采集配置逻辑。
操作页面:
配置项 | 说明 |
---|---|
Topic | 选择需要采集的Topic |
读取类型 | 支持Json、Text格式 |
Offset | Offset解释:消费者消费完了消息是不会被立刻删除的,每个消费者把消费的数据消费到哪里了就需要做个记录,就是offset。 在采集时,我们就需要指定从哪个offset开始消费。目前支持:group、latest、earliest、指定时间、自定义偏移量。 |