Interceptor in Apache Flume

  • Apache Flume offers interceptors as a method of modifying records as they have a Flume channel.
  • Interceptors are used to filter the events between source and channel, channel and sink. These channels will filter un-necessary or targeted log files.
apache flume features
  • Interceptors are a part of Flume’s extensibility model. They permit events to be inspected as they pass between a source and a channel, and also the developer is liberated to modify or drop events as needed. Interceptors in the chain along to create a pipeline process.
apache flume features

Categorized in: