i made a very bad assumption that the list of TopicPartitions passed into the assign and revoke callbacks would be nonempty. this is causing uncaught exception and consumer restart. i've removed this assumption. didn't need it anyway. it was used just for logging, but there was no useful information contained within
i made a very bad assumption that the list of TopicPartitions passed into the assign and revoke callbacks would be nonempty. this is causing uncaught exception and consumer restart. i've removed this assumption. didn't need it anyway. it was used just for logging, but there was no useful information contained within