Hi,
For the producer, we have moved to a new producer API (under
org.apache.kafka.clients.producer.KafkaProducer). Please feel free to give
that a spin and report any issues that you see.
I think the consumer issue you reported is being discussed in another
thread and is fixed in 0.8.2. Can you c
Hi,
I'm using kafka-0.8.1.1, this is a good log system, and I'm very appreciate
for your works. But I'm also found some problem:
1. producer：
kafka.producer.async.DefaultEventHandler.scala handle(): I suggest that
sendPartitionPerTopicCache should be cleared every batch, since It wo
