You can configure the Java Agent to detect entry points for Apache Kafka consumer activity using KafkaConsumer.poll() (introduced in Kafka v0.10) and Kafka SimpleConsumer.fetch() (introduced in Kafka v0.9). Prior to version 0.11, the Kafka payload did not include a location to store correlation data, so end-to-end Business Transaction correlation is only possible with the Kafka client and broker >= 0.11.