kafka基本配置使用。
主要步骤如下:
《组件页面》
选择Kafka对应的数据源信息,配置topic以及消费组名称,下方可配置额外的连接信息。
以auto.offset.reset = latest(从分区的最新的记录开始消费,即从最新的offset开始消费) 为例:
对组件进行保存->提交->运行,此时kafka一直处于挂起状态,等待消息输入。
Kafka输出组件进行消息输入,配置参考Kafka输出组件配置,输出完毕之后Kafka输入组件则会接收到对应topic的信息。