


As a migration step check if there are any offsets from the group stored in kafka // If not read them from Zookeeper and commit them to Kafka if (migrateZookeeperOffsets & zookeeperConnect != null & !zookeeperConnect.isEmpty()) started. Apache Kafka is a very popular system for message delivery and subscription, and provides a number of extensions that increase its versatility and power. Problem with sending message from flume to kafka Ask Question Asked 4 years ago Modified 4 years ago Viewed 948 times 1 I have two hosts in two different VMs, i have flume on a Centos 7 host and kafka on cloudera host. Data loss (missing) using Flume with Kafka source and HDFS sink. There, the log files can be consumed by analytical tools like Spark or Kafka.
