public interface KafkaRecordProcessor<K,V>
void
processKafkaRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
void processKafkaRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Copyright © 2016. All rights reserved.