public interface EsperIOKafkaInputSubscriber
void
subscribe(EsperIOKafkaInputSubscriberContext context)
void subscribe(EsperIOKafkaInputSubscriberContext context)