diff --git a/src/main/java/com/github/danielwegener/logback/kafka/KafkaAppender.java b/src/main/java/com/github/danielwegener/logback/kafka/KafkaAppender.java
index 104af50..7753fa1 100644
--- a/src/main/java/com/github/danielwegener/logback/kafka/KafkaAppender.java
+++ b/src/main/java/com/github/danielwegener/logback/kafka/KafkaAppender.java
@@ -24,7 +24,7 @@ public class KafkaAppender<E> extends KafkaAppenderConfig<E> {
      * Kafka clients uses this prefix for its slf4j logging.
      * This appender defers appends of any Kafka logs since it could cause harmful infinite recursion/self feeding effects.
      */
-    private static final String KAFKA_LOGGER_PREFIX = "org.apache.kafka.clients";
+    private static final String KAFKA_LOGGER_PREFIX = "org.apache.kafka";
 
     private LazyProducer lazyProducer = null;
     private final AppenderAttachableImpl<E> aai = new AppenderAttachableImpl<E>();
@@ -44,10 +44,10 @@ public KafkaAppender() {
 
     @Override
     public void doAppend(E e) {
-        ensureDeferredAppends();
         if (e instanceof ILoggingEvent && ((ILoggingEvent)e).getLoggerName().startsWith(KAFKA_LOGGER_PREFIX)) {
             deferAppend(e);
         } else {
+            ensureDeferredAppends();
             super.doAppend(e);
         }
     }