Kafka011

功能介绍

读Kafka 0.11版

参数说明

名称 中文名称 描述 类型 是否必须? 默认值
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 = Kafka011SourceStreamOp() \
  2. .setBootstrapServers("localhost:9092") \
  3. .setTopic("iris") \
  4. .setStartupMode("EARLIEST") \
  5. .setGroupId("alink_group")
  6. data.print()
  7. StreamOperator.execute()