Context: Spark Streaming menggunakan kemampuan penjadwalan cepat Spark Core untuk melakukan analisis streaming. Ini mengonsumsi data dalam mini-batch dan melakukan transformasi RDD pada mini-batch data tersebut. Desain ini memungkinkan satu set kode aplikasi yang sama yang ditulis untuk analisis batch untuk digunakan dalam analisis streaming, sehingga memfasilitasi implementasi arsitektur lambda yang mudah. Namun, kenyamanan ini dilengkapi dengan hukuman latensi yang sama dengan durasi mini-batch. Mesin data streaming lainnya yang memproses acara per acara daripada dalam mini-batch termasuk Storm dan komponen streaming Flink. Spark Streaming memiliki dukungan bawaan untuk mengkonsumsi dari soket Kafka, Flume, Twitter, ZeroMQ, Kinesis, dan TCP / IP.

Dari bagian yang diberikan, ekstrak konsumen yang didukung untuk streaming Spark. Pisahkan mereka dengan koma.

Kafka, Flume, Twitter, ZeroMQ, Kinesis, TCP/IP socket