介绍
该连接器使用Twitter流API侦听状态更新消息,并将其即时转换为Kafka Connect结构。 目标是尽可能匹配Twitter状态对象。
组态
TwitterSourceConnector
这个Twitter Source连接器用于实时从Twitter提取数据。
name =connector1
tasks.max =1
connector.class =com.github.jcustenborder.kafka.connect.twitter.TwitterSourceConnector
# Set these required values
twitter.oauth.a
评论0
最新资源