• Kafka011
    • 功能介绍
    • 参数说明
    • 脚本示例

    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
    startTime 起始时间 起始时间。默认从当前时刻开始读。 String null

    脚本示例

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