Revert "feat: use buildAndRegisterGlobal (#43)" (#44)

This reverts commit b9cd0b7.

Author: mulmuri

src/main/java/io/goboolean/streams/kafka/KafkaAggregateConsumerService.java

@@ -11,8 +11,6 @@
 
 public class KafkaAggregateConsumerService {
 
-    private static final Logger logger = LoggerFactory.getLogger(KafkaAggregateConsumerService.class);
-
     private final Properties props;
     private final Consumer<Integer, Model.Aggregate> consumer;
     private final KafkaConsumerListener listener;
@@ -33,15 +31,9 @@ public void run(String[] topics) {
 
         pollingThread = new Thread(() -> {
             while (!Thread.currentThread().isInterrupted()) {
-                try {
-                    consumer.poll(100).forEach(record -> {
-                        logger.debug("Received message - Topic: {}, Partition: {}, Offset: {}",
-                            record.topic(), record.partition(), record.offset());  
-                        listener.onMessage(record.value());
-                    });
-                } catch (Exception e) {
-                    logger.error("Error polling Kafka", e);
-                }
+                consumer.poll(100).forEach(record -> {
+                    listener.onMessage(record.value());
+                });
             }
         });
         pollingThread.start();