diff --git a/src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java b/src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java index f394890b..972a85f6 100644 --- a/src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java +++ b/src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java @@ -90,7 +90,7 @@ String tag() { public static final boolean DEFAULT_BLOCKING = false; public static final boolean DEFAULT_ENABLE_TELEMETRY = true; - public static final boolean DEFAULT_ENABLE_AGGREGATION = false; + public static final boolean DEFAULT_ENABLE_AGGREGATION = true; public static final String CLIENT_TAG = "client:java"; public static final String CLIENT_VERSION_TAG = "client_version:"; diff --git a/src/test/java/com/timgroup/statsd/TelemetryTest.java b/src/test/java/com/timgroup/statsd/TelemetryTest.java index 0ad40f35..687f2f89 100644 --- a/src/test/java/com/timgroup/statsd/TelemetryTest.java +++ b/src/test/java/com/timgroup/statsd/TelemetryTest.java @@ -97,6 +97,7 @@ public StatsDNonBlockingTelemetry(final String prefix, final int queueSize, Stri .processorWorkers(processorWorkers) .senderWorkers(senderWorkers) .blocking(blocking) + .enableAggregation(false) .enableTelemetry(enableTelemetry) .telemetryFlushInterval(telemetryFlushInterval) .resolve());