A.KafkaUtils.createStream(....) B.KafkaUtils.createDirectStream(....) C.StreamingContext.socketStream(....) D.StreamingContext.fileStream(....)
A.Kafka集群安全访问端口默认为21007,非安全访问端口默认为21005 B.旧API通过21005端口访问某个Topic的前ᨀ是:服务端参数allow.everyone.if.no.acl.found设置为true,且此Topic未设置ACL属性 C.旧API仅支持访问21005端口;新API兼容访问非安全端口21005和安全端口21007 D.对于设置了ACL的Topic,可以使用旧API连接21005端口进行访问