Issue-334 fix to handle when the event is not added to queue in case of queue full for concurrenthec

Author: ashish8678

README.md

@@ -1,4 +1,4 @@
-## Splunk Connect for Kafka test
+## Splunk Connect for Kafka
 
 Splunk Connect for Kafka is a Kafka Connect Sink for Splunk with the following features:
 

src/main/java/com/splunk/hecclient/ConcurrentHec.java

@@ -57,7 +57,11 @@ public ConcurrentHec(int numberOfThreads, boolean useAck, HecConfig config, Poll
     @Override
     public final void send(final EventBatch batch) {
         try {
-            batches.offer(batch, 1000, TimeUnit.MILLISECONDS);
+            boolean offerSuccess = batches.offer(batch, 1000, TimeUnit.MILLISECONDS);
+            if (!offerSuccess) {
+                log.warn("Linked blocking queue is full (size = {}) for event batch = {}, failed to offer batch into queue", batches.size(), batch.getUUID());
+                throw new HecException("linked blocking event queue is full, failed to offer batch into queue");
+            }
         } catch (InterruptedException ex) {
             throw new HecException("failed to offer batch into queue", ex);
         }