diff --git a/spring-cloud-stream-binders/spring-cloud-stream-binder-spi/src/main/java/org/springframework/cloud/stream/binder/BinderProperties.java b/spring-cloud-stream-binders/spring-cloud-stream-binder-spi/src/main/java/org/springframework/cloud/stream/binder/BinderProperties.java index 57cb7f2ba..15f170def 100644 --- a/spring-cloud-stream-binders/spring-cloud-stream-binder-spi/src/main/java/org/springframework/cloud/stream/binder/BinderProperties.java +++ b/spring-cloud-stream-binders/spring-cloud-stream-binder-spi/src/main/java/org/springframework/cloud/stream/binder/BinderProperties.java @@ -119,12 +119,12 @@ public interface BinderProperties { /** * For all non-terminal modules, the number of modules coming after this one, irrespective of partitioning. */ - public static final String NEXT_MODULE_COUNT = "next.module.count"; + public static final String NEXT_MODULE_COUNT = "nextModuleCount"; /** * For all non-terminal modules, the concurrency for module coming after this one. */ - public static final String NEXT_MODULE_CONCURRENCY = "next.module.concurrency"; + public static final String NEXT_MODULE_CONCURRENCY = "nextModuleConcurrency"; /** * Compression enabled.