Kafka数据接入

• 用途：从Kafka接收数据，发送到算盘下一个节点
• 要求：Kafka的topic中数据为json格式字符串
• 输出：json格式
• 参数说明
  • 发送间隔：组件从kafka获取数据，并向下发送的时间间隔
  • Kafka Broker地址：格式如broker1:9092,broker2:9092
  • 消费组（Consumer Group）
  • offset重置位置：当offset不存在时，开始消费的位置
  • 消费主题（Topic）
  • 单次消费最大条数
  • 消费超时时间