The following call will hang for the processing timeout in the consumer.
consumer.offsetsForTimes(new util.HashMap[TopicPartition, java.lang.Long]())
- links to
The following call will hang for the processing timeout in the consumer.
consumer.offsetsForTimes(new util.HashMap[TopicPartition, java.lang.Long]())