A.KafkaUtils.createStream(....) B.KafkaUtils.createDirectStream(....) C.StreamingContext.socketStream(....) D.StreamingContext.fileStream(....)
A.Kafka集群安全訪問端口默認為21007,非安全訪問端口默認為21005 B.舊API通過21005端口訪問某個Topic的前ᨀ是:服務端參數(shù)allow.everyone.if.no.acl.found設置為true,且此Topic未設置ACL屬性 C.舊API僅支持訪問21005端口;新API兼容訪問非安全端口21005和安全端口21007 D.對于設置了ACL的Topic,可以使用舊API連接21005端口進行訪問