Long offset = consumer.position(tp);
log.info("{} - adding partition: {}, offset={}", id, partition, offset);
offsets.put(partition, offset);
Long offset = consumer.position(tp);
log.info("{} - adding partition: {}, offset={}", id, partition, offset);
offsets.put(partition, offset);