Kafka

功能介绍

读Kafka, 支持kafka 1.x和2.x版

参数说明

名称 中文名称 描述 类型 是否必须？ 默认值
bootstrapServers “bootstrap.servers” “bootstrap.servers” String ✓
groupId “group.id” “group.id” String ✓
startupMode “startupMode” “startupMode”, “EARLIEST”,”GROUP_OFFSETS”,”LATEST”,”TIMESTAMP” String ✓
topic topic名称 topic名称 String null
topicPattern “topic pattern” “topic pattern” String null
properties 额外的kafka参数配置 额外的kafka参数配置，格式形如”prop1=val1,prop2=val2” String
startTime 起始时间 起始时间。默认从当前时刻开始读。 String null

脚本示例

  1. data = KafkaSourceStreamOp() \
  2.     .setBootstrapServers("localhost:9092") \
  3.     .setTopic("iris") \
  4.     .setStartupMode("EARLIEST") \
  5.     .setGroupId("alink_group")
  7. data.print()
  8. StreamOperator.execute()