commit d5e18681bb90909b6db8b6e5139ab86c2f07e5fe
author Jason Huynh <huynhja@gmail.com> Wed Apr 01 09:31:58 2020 -0700
committer Jason Huynh <huynhja@gmail.com> Wed Apr 01 09:31:58 2020 -0700
tree cef5d459ddf6ab39f02cb86b699650e3a0921ea3
parent 3c3804b85d18a0c485a798bf237997469bf1fa1c

Added additional info logging if queue is full

src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java

diff --git a/src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java b/src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java
index f2f3142..ae96997 100644
--- a/src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java
+++ b/src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java
@@ -44,6 +44,7 @@
     try {
       eventBufferSupplier.get().offer(new GeodeEvent(regionName, aCqEvent), 2, TimeUnit.SECONDS);
     } catch (InterruptedException e) {
+      logger.info("GeodeKafkaSource Queue is full, waiting to offer");
 
       while (true) {
         try {