Is this a single instance with wildcarding of topics? Please share config
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.
On Sun, Jun 10, 2018, 9:21 PM Faisal Durrani <[EMAIL PROTECTED]> wrote: