Kafka输入

kafka基本配置使用。

主要步骤如下：

• 模型
• 开发步骤
  • 组件页面

模型

开发步骤

《组件页面》

选择Kafka对应的数据源信息，配置topic以及消费组名称，下方可配置额外的连接信息。

以auto.offset.reset = latest（从分区的最新的记录开始消费，即从最新的offset开始消费） 为例：

对组件进行保存->提交->运行，此时kafka一直处于挂起状态，等待消息输入。

Kafka输出组件进行消息输入，配置参考Kafka输出组件配置，输出完毕之后Kafka输入组件则会接收到对应topic的信息。