1.2.1

v1.2.1

bump version for release 1.2.1

1.2.0

New Feature

• [ #12] Add a default reader for reading XML source file.

1.1.0

New Feature

• [ #2] Add new filter JoinFilter
• [ #3] Add new filter DateFilter
• [ #9] Add new ByteArrayInputFileReader
• [#10] Add new AvroFilterInputReader

Improvement

• [ #8] Make configuration 'filters' optional

Bug

• [ #7] Fix NPE when no filter is configured

1.0.0

New Features

• Add support for recursive local directories scan.
• Add support for filtering input files.
• Add support for compressed files (GZIP, TARG, ZIP).
• Add support for filter chain.
• Add support for filter conditional execution.
• Add support for cleanup policies.
• Add support for Simple Connect Expression Language.
• Add support for defining the record timestamp (via AppendFilter).
• Add support for defining the record key (via AppendFilter).
• Add support for defining the record topic (via AppendFilter).
• Add support for defining the record partition (via AppendFilter).
• Add support for defining the record headers (via AppendFilter).

List of new filters

• AppendFilter
• ConvertFilter
• DelimitedRowFilter
• DropFilter
• FailFilter
• GrokFilter
• GroupRowFilter
• JSONFilter
• MultiRowFilter
• RenameFilter
• SplitFilter