diff --git a/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelConsumerOptions.java b/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelConsumerOptions.java index 9b088191a..79cbe7af0 100644 --- a/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelConsumerOptions.java +++ b/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelConsumerOptions.java @@ -426,7 +426,7 @@ private void validateMinBatchParameters() { if (isEnforceMinBatch()){ if (minBatchSize > batchSize) throw new IllegalArgumentException( - msg("minBatchSize can not by bigger than batchSize: {} > {}", + msg("minBatchSize cannot be bigger than batchSize: {} > {}", minBatchSize, batchSize)); }