added logic to stop current consumer and create a new instance if any batch of messages fails to send to Splunk HEC. This helps to guarantee delivery to Splunk for the messages that failed to send. I should add a back-off policy but this seems to work for now.
added logic to stop current consumer and create a new instance if any batch of messages fails to send to Splunk HEC. This helps to guarantee delivery to Splunk for the messages that failed to send. I should add a back-off policy but this seems to work for now.

sghaskell/kafka-splunk-consumer