Description

Data source for kafka 0.10

Parameters

Name Description Type Required？ Default Value
bootstrapServers kafka bootstrap servers String ✓
groupId consumer group id String ✓
startupMode startupMode String ✓
topic topic String null
topicPattern topic pattern String null
properties additional kafka configurations additional kafka configurations, such as “prop1=val1,prop2=val2” String
startTime start time String null

Script Example

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