Added some logging

.github/workflows/build.yml

@@ -6,6 +6,14 @@ on:
         description: "The branch to use to build a SNAPSHOT from."
         required: true
         default: "main"
+      skip-tests:
+        type: choice
+        description: Whether to skip tests?
+        required: false
+        options:
+          - "true"
+          - "false"
+        default: "false"
 jobs:
   deploy:
     name: Build SNAPSHOT to Sonatype
@@ -33,7 +41,7 @@ jobs:
           settings-path: ${{ github.workspace }}
 
       - name: Run Maven Targets
-        run: mvn deploy jacoco:report checkstyle:checkstyle spotbugs:spotbugs --settings $GITHUB_WORKSPACE/settings.xml --batch-mode --show-version --no-transfer-progress --activate-profiles sonatype-oss-release-github-actions
+        run: mvn deploy -DskipTests=${{ github.event.inputs.skip-tests }} jacoco:report checkstyle:checkstyle spotbugs:spotbugs --settings $GITHUB_WORKSPACE/settings.xml --batch-mode --show-version --no-transfer-progress --activate-profiles sonatype-oss-release-github-actions
         env:
           SONATYPE_USERNAME: ${{ secrets.SONATYPE_USERNAME }}
           SONATYPE_PASSWORD: ${{ secrets.SONATYPE_PASSWORD }}

beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java

@@ -72,6 +72,9 @@ public ExpiredHousekeepingMetadataGenerator(String cleanupDelay) {
   @Override
   public List<HousekeepingEntity> generate(ListenerEvent listenerEvent, String clientId) {
     List<HousekeepingEntity> housekeepingEntities = new ArrayList<>();
+    log
+    .info("Processing '{}' event for table: {}.{}", listenerEvent.getEventType(), listenerEvent.getDbName(),
+        listenerEvent.getTableName());
 
     switch (listenerEvent.getEventType()) {
     case CREATE_TABLE:

beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/UnreferencedHousekeepingPathGenerator.java

@@ -69,6 +69,9 @@ public UnreferencedHousekeepingPathGenerator(String cleanupDelay) {
   @Override
   public List<HousekeepingEntity> generate(ListenerEvent listenerEvent, String clientId) {
     List<HousekeepingEntity> housekeepingEntities = new ArrayList<>();
+    log
+    .info("Processing '{}' event for table: {}.{}", listenerEvent.getEventType(), listenerEvent.getDbName(),
+        listenerEvent.getTableName());
 
     switch (listenerEvent.getEventType()) {
     case ALTER_PARTITION:

beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java

@@ -1,5 +1,5 @@
 /**
- * Copyright (C) 2019-2023 Expedia, Inc.
+ * Copyright (C) 2019-2024 Expedia, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -45,9 +45,12 @@ public MessageEventHandler(HousekeepingEntityGenerator generator, List<ListenerE
 
   public List<HousekeepingEntity> handleMessage(MessageEvent event) {
     ListenerEvent listenerEvent = event.getEvent();
+    log.info("Filtering message {}, generator {}", filters, generator.getClass().getSimpleName());
     if (shouldFilterMessage(listenerEvent)) {
+      log.info("Filtered message {}", event);
       return Collections.emptyList();
     }
+    log.info("Filtered message");
     return generateHousekeepingEntities(listenerEvent);
   }
 

beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/messaging/MessageReaderAdapter.java

@@ -54,7 +54,7 @@ public Optional<BeekeeperEvent> read() {
     }
 
     MessageEvent message = messageEvent.get();
-
+    log.info("Received message: {}", message);
     List<HousekeepingEntity> housekeepingEntities = handlers.parallelStream()
         .map(eventHandler -> eventHandler.handleMessage(message))
         .flatMap(Collection::stream)