Constructor and Description |
---|
EsperIOKafkaInputRunnable(org.apache.kafka.clients.consumer.KafkaConsumer consumer,
EsperIOKafkaInputProcessor processor) |
public EsperIOKafkaInputRunnable(org.apache.kafka.clients.consumer.KafkaConsumer consumer, EsperIOKafkaInputProcessor processor)