diff --git a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java index 6c60cd41bf12f..ce1f2f8f25324 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java +++ b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java @@ -98,7 +98,7 @@ private Flux listBlobs(String prefix, Function> convert private Mono convertToCheckpoint(BlobItem blobItem) { String[] names = blobItem.getName().split(BLOB_PATH_SEPARATOR); - logger.info(Messages.FOUND_BLOB_FOR_PARTITION, blobItem.getName()); + logger.verbose(Messages.FOUND_BLOB_FOR_PARTITION, blobItem.getName()); if (names.length == 5) { // Blob names should be of the pattern // fullyqualifiednamespace/eventhub/consumergroup/checkpoints/ @@ -110,7 +110,7 @@ private Mono convertToCheckpoint(BlobItem blobItem) { } Map metadata = blobItem.getMetadata(); - logger.info(Messages.CHECKPOINT_INFO, blobItem.getName(), metadata.get(SEQUENCE_NUMBER), + logger.verbose(Messages.CHECKPOINT_INFO, blobItem.getName(), metadata.get(SEQUENCE_NUMBER), metadata.get(OFFSET)); Long sequenceNumber = null; @@ -171,7 +171,7 @@ public Flux claimOwnership(List requeste .uploadWithResponse(Flux.just(UPLOAD_DATA), 0, null, metadata, null, null, blobRequestConditions) .flatMapMany(response -> updateOwnershipETag(response, partitionOwnership), error -> { - logger.info(Messages.CLAIM_ERROR, partitionId, error.getMessage()); + logger.verbose(Messages.CLAIM_ERROR, partitionId, error.getMessage()); return Mono.empty(); }, Mono::empty); } else { @@ -179,7 +179,7 @@ public Flux claimOwnership(List requeste blobRequestConditions.setIfMatch(partitionOwnership.getETag()); return blobAsyncClient.setMetadataWithResponse(metadata, blobRequestConditions) .flatMapMany(response -> updateOwnershipETag(response, partitionOwnership), error -> { - logger.info(Messages.CLAIM_ERROR, partitionId, error); + logger.verbose(Messages.CLAIM_ERROR, partitionId, error); return Mono.empty(); }, Mono::empty); } @@ -247,7 +247,7 @@ private String getBlobName(String fullyQualifiedNamespace, String eventHubName, } private Mono convertToPartitionOwnership(BlobItem blobItem) { - logger.info(Messages.FOUND_BLOB_FOR_PARTITION, blobItem.getName()); + logger.verbose(Messages.FOUND_BLOB_FOR_PARTITION, blobItem.getName()); String[] names = blobItem.getName().split(BLOB_PATH_SEPARATOR); if (names.length == 5) { // Blob names should be of the pattern @@ -258,7 +258,7 @@ private Mono convertToPartitionOwnership(BlobItem blobItem) return Mono.empty(); } logger - .info(Messages.BLOB_OWNER_INFO, blobItem.getName(), + .verbose(Messages.BLOB_OWNER_INFO, blobItem.getName(), blobItem.getMetadata().getOrDefault(OWNER_ID, EMPTY_STRING)); BlobItemProperties blobProperties = blobItem.getProperties(); diff --git a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventProcessorClient.java b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventProcessorClient.java index b72acfa4054c1..681220816cec4 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventProcessorClient.java +++ b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventProcessorClient.java @@ -55,8 +55,6 @@ public class EventProcessorClient { private final String eventHubName; private final String consumerGroup; - - /** * Package-private constructor. Use {@link EventHubClientBuilder} to create an instance. * diff --git a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/PartitionPumpManager.java b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/PartitionPumpManager.java index 510c42f1ae84e..adacf1196d8a6 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/PartitionPumpManager.java +++ b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/PartitionPumpManager.java @@ -106,7 +106,7 @@ void stopAllPartitionPumps() { */ void startPartitionPump(PartitionOwnership claimedOwnership, Checkpoint checkpoint) { if (partitionPumps.containsKey(claimedOwnership.getPartitionId())) { - logger.info("Consumer is already running for this partition {}", claimedOwnership.getPartitionId()); + logger.verbose("Consumer is already running for this partition {}", claimedOwnership.getPartitionId()); return; }