Re: how to listen each partition with separate threads ?

[Matthias J. Sax]

You need to create a KafkaConsumer per thread.

-Matthias

On 3/30/17 10:51 PM, Laxmi Narayan wrote:
> Hi ,
> 
> I was thinking to listen each partition with separate thread in Kafka.
> But i get error saying :
> 
> 
> 
> 
> *org.apache.kafka.clients.consumer.KafkaConsumer@383ad023KafkaConsumer is
> not safe for multi-threaded accessSubscription to topics, partitions and
> pattern are mutually exclusive.*​
> 
>  Is there any way to achieve this ?
> 
> 
> *​​*
> Keep learning keep moving .....
> 

signature.asc
Description: OpenPGP digital signature