int partition = topicPartition.partition();
isShardOwned[partition] = false;
nextOffset[partition] = consumer.position(topicPartition);
int partition = topicPartition.partition();
isShardOwned[partition] = false;
nextOffset[partition] = consumer.position(topicPartition);