Hi, I had a client running on Kafka 0.8.1 using the High-Level consumer API working fine.
Today I updated my Kafka installation for the 0.8.2 version (tried all versions of Scala) but the consumer doesn't get any messages. I tested using the kafka-console-consumer.sh utility tool and works fine, only my Java program that not. Did I miss something? I heard that the API changed, so I'd like to know if someone can share a simple client with me. Please, respond directly to me or just reply all because I am not currently subscribed to the group. Thanks, Ricardo Ferreira