Sorry.    I should have added the "key" for Kafka messages as flume event event headers. Adding hostname interceptor with name as key solved my issue.  kafkaproducer.sources.tail1.interceptors.i1.type = org.apache.flume.interceptor.HostInterceptor$Builder kafkaproducer.sources.tail1.interceptors.i1.preserveExisting = false kafkaproducer.sources.tail1.interceptors.i1.hostHeader = key ... View more