Hello

Is this a single instance with wildcarding of topics?  Please share config
details.

If you want that in a single instance you may need to alter the timeout
associated with any single kafka consumer.  The assignment will be per
topic per partion.  How many he threads for that processor?

Finally, consider using ConsumeKafkaRecord and if you are using kaka 1 or
newer use the latest processor.

thanks

On Sun, Jun 10, 2018, 9:21 PM Faisal Durrani <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB