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();
}

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 ( ) ; }
use the supplied function to asynchronously consume messages from the cluster .
