Umesh

Thanks @simonati. Will update the PR soon with synchronized messages amongst Kafka source/channel/sink.

@simonati, I have made the suggested changes. Please let me know your thoughts.

Tests are passing locally on trunk : Command: ` mvn -DfailIfNoTests=false -Dtest=org.apache.flume.channel.kafka.TestKafkaChannel#testAutomaticOffsetsMigration clean test` Running org.apache.flume.channel.kafka.TestKafkaChannel Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 90.408 sec Results...

Thanks @harishreedharan for your comment. Actually in the committed TestKafkaChannel.java file there are no such violations which are pointed by Travis. May I request you to verify the first one...

Thanks @simonati for pointing the checkstyle issues. Please review the updated commit.

@jeremybeard : do you mean in KuduStorageTable and DelimitedTranslator ? "java.math.BigDecimal" ?

Sure, @jeremybeard , got it, Thanks!