FLUME-2857. Make Kafka Source/Channel/Sink restore default values when live updating...
authorTristan Stevens <tristan@cloudera.com>
Fri, 28 Oct 2016 12:24:02 +0000 (14:24 +0200)
committerBessenyei Balázs Donát <bessbd@apache.org>
Fri, 28 Oct 2016 12:24:02 +0000 (14:24 +0200)
commit14fb4d84fd0e100253ca947bc96810c242e7a82b
tree7004dec93fd3982a7b43eec47ad1bc0c12e91d9d
parent5bf1d9b7b06365d19ccc374f0ed58a3c97e96a7c
FLUME-2857. Make Kafka Source/Channel/Sink restore default values when live updating config

This commit changes Kafka Channel, Sink and Source to fix an error where
sub-configurations aren't tolerant of the configure() method being called more
than once (as happens when a Live Config Update happens).

Reviewers: Denes Arvay, Attila Simon, Bessenyei Balázs Donát

(Tristan Stevens via Bessenyei Balázs Donát)
flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java
flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java
flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java