Hi King,
So, I think the issue could be which consumer you are using. Are you
using the simple consumer or the high level consumer API? And which
version of kafka are you using?
If you are using the simple consumer API, you can listen to a specific
partition. But you have to do the failover cod
Hi all ,
I'm a user of kafka(version is kafka_2.10-0.8.2.0), but recently I met a
problem annoying me for a time.
I create a topic named A for example. this topic has 18 partitions ,and run
9 webservices on 9 servers to consume this topic,each service consume 2
partitions configured in file .