question: public < K , V > void consume ( String groupId , String clientId , OffsetResetStrategy autoOffsetReset , Deserializer < K > keyDeserializer , Deserializer < V > valueDeserializer , BooleanSupplier continuation , OffsetCommitCallback offsetCommitCallback , Runnable completion , Collection < String > topics , java . util . function . Consumer < ConsumerRecord < K , V > > consumerFunction ) { Properties props = getConsumerProperties ( groupId , clientId , autoOffsetReset ) ; Thread t = new Thread ( null ) ; t . setName ( clientId + "-thread" ) ; t . start ( ) ; }
target:  Use the supplied function to asynchronously consume messages from the cluster.