介绍 该连接器使用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