In Flume, what is the main function of the source function module?

Question

Options

• AObtain data and convert the original data into data objects that you process
• BCache data and save the data in memory or files according to different reliability strategies
• COutput data to destination, support multiple output protocols
• DSplit the data and send the data to different destinations according to the characteristics of the

• A
  83% (34)
• B
  10% (4)
• C
  5% (2)
• D
  2% (1)

Explanation

Option A is correct because in Apache Flume's architecture, the Source component is responsible for ingesting data from external systems (like log files, Kafka, HTTP endpoints) and converting that raw input into Flume Event objects - the internal data format that flows through the pipeline.

Why the distractors are wrong:

• B describes the Channel, which buffers/caches events between the source and sink using strategies like in-memory or file-based persistence.
• C describes the Sink, which writes data to a destination (HDFS, HBase, Kafka, etc.) using various output protocols.
• D describes a Channel Selector or Multiplexing Channel, which routes events to different channels/sinks based on event headers or content.

Memory tip: Think of Flume's three core components in order - Source → Channel → Sink - as "Scoop, Store, Send." The Source scoops data in and shapes it; the Channel stores it reliably; the Sink sends it out. Any question about ingestion and conversion belongs to the Source.

No community discussion yet for this question.