class Karafka::BaseConsumer
def consume
- Note: - This method needs bo be implemented in a subclass. We stub it here as a failover if
def consume raise NotImplementedError, 'Implement this in a subclass' end
def consume raise NotImplementedError, 'Implement this in a subclass' end