I'm not quite sure if I fully understood your question. The consumer API exposes a close() method that will shutdown the consumer's connections to all brokers and frees up resources that the consumer uses.
I've updated the javadoc for the new consumer API to include a few examples of different ways of using the consumer. Probably you might find it useful - http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/kafka/clients/consumer/KafkaConsumer.html Thanks, Neha On Sun, Mar 16, 2014 at 7:55 PM, Shanmugam, Srividhya < srividhyashanmu...@fico.com> wrote: > Can the consumer API provide a way to shut down the connector by doing a > look up by the consumer group Id? For example, application may be consuming > the messages in one thread whereas the shutdown call can be initiated in a > different thread. > > This email and any files transmitted with it are confidential, proprietary > and intended solely for the individual or entity to whom they are > addressed. If you have received this email in error please delete it > immediately. >
