Interface TopicPartitionConsumerFunction


  • public interface TopicPartitionConsumerFunction
    • Method Detail

      • execute

        void execute​(java.lang.String topic,
                     int partition)