int partition = topicPartition.partition();
isShardOwned[partition] = false;
log.info("Partition revoked: {} - next={}", partition, nextOffset[partition]);
int partition = topicPartition.partition();
isShardOwned[partition] = false;
log.info("Partition revoked: {} - next={}", partition, nextOffset[partition]);