// make the consumer available for graceful shutdown
setKafkaConsumer(consumer);
consumer.assign(Collections.singleton(new TopicPartition(topicName, 0)));
// make the consumer available for graceful shutdown
setKafkaConsumer(consumer);
consumer.assign(Collections.singleton(new TopicPartition(topicName, 0)));