----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51244/ -----------------------------------------------------------
Review request for Flume. Repository: flume-git Description ------- I found Flume OG's decorators to handle event headers useful and some to be missing from Flume NG. More specifically, we could have an interceptor to remove headers from an event. Diffs ----- c/flume-ng-core/src/main/java/org/apache/flume/interceptor/InterceptorType.java fe341e9 c/flume-ng-doc/sphinx/FlumeUserGuide.rst 1c15f1e w/flume-ng-core/src/main/java/org/apache/flume/interceptor/RemoveHeaderInterceptor.java PRE-CREATION w/flume-ng-core/src/test/java/org/apache/flume/interceptor/RemoveHeaderInterceptorTest.java PRE-CREATION Diff: https://reviews.apache.org/r/51244/diff/ Testing ------- All tests (besides the FLUME-2974-related ones) in flume-ng-core run successfully I've used this config for manual testing: a1.sources = r1 a1.sources.r1.type = netcat a1.sources.r1.bind = 0.0.0.0 a1.sources.r1.port = 6666 a1.sources.r1.channels = c1 a1.channels = c1 a1.channels.c1.type = memory a1.channels.c1.capacity = 10000 a1.channels.c1.transactionCapacity = 10000 a1.channels.c1.byteCapacityBufferPercentage = 20 a1.channels.c1.byteCapacity = 800000 a1.channels = c1 a1.sinks = k1 a1.sinks.k1.type = logger a1.sinks.k1.channel = c1 a1.sources.r1.interceptors = i1 i2 i3 a1.sources.r1.interceptors.i1.type = timestamp a1.sources.r1.interceptors.i2.type = host a1.sources.r1.interceptors.i2.hostHeader = hostname a1.sources.r1.interceptors.i3.type = remove_header a1.sources.r1.interceptors.i3.with.name = timestamp Thanks, Balázs Donát Bessenyei
