The lastConnectionTime adjustment is also in this patch.
Also the following file is also affected. Curious, in the repository copy, the variable "event" has no context (an variable not defined), only when I change it to events the make process can succeed.
— core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala (revision 1245727)
+++ core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala (working copy)
@@ -38,8 +38,8 @@
processedEvents = cbkHandler.beforeSendingData(events)
- processedEvents.foreach(event => trace("Handling event for Topic: %s, Partition: %d"
- .format(event.getTopic, event.getPartition)))
+ processedEvents.foreach(events => trace("Handling event for Topic: %s, Partition: %d"
+ .format(events.getTopic, events.getPartition)))
send(serialize(collate(processedEvents), serializer), syncProducer)