enable.idempotence=true and Retriable exceptions

I currently catch and retry Retriable exceptions. The v11 docs say if enable.idempotence=true than my application shouldn’t retry if these exceptions are thrown because my retries wouldn’t be idempotent. Am I supposed to ignore these exceptions now? I use the Java driver. Gary

0.9 client AbstractCoordinator - Attempt to join group failed due to obsolete coordinator information

Hi, My local Java client consumer and producer fail with log messages I don’t understand. What does "obsolete coordinator information” mean? 2016-02-16 18:49:01,795 INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.9.0.0 2016-02-16 18:49:01,795 INFO o.a.kafka.common.utils.AppInfo

Getting started with 0.9 client custom serialization

It looks like the gist of it is to use the client’s ByteArraySerializer/ByteArrayDeserializer. Can someone point me to nice examples for Json or Avro or Scala case classes with the 0.9 Kafka Java client? Googling for answers produces too much noise to wade through. Thanks, Gary

Java client 0.9 poll doesn't return

Calling the stand alone client (org.apache.kafka" % "kafka-clients" % “0.9.0.0”) from Scala, consumer.poll never returns. I’ve tried both assign TopicPartition and subscribe and various timeouts and I’ve quintuple checked config properties. Here’s a Scala-Ide worksheet val props = loadProper