Skip to content

Commit 05237ea

Browse files
committed
GH-3147 Remove 'consumerPriority' from KafkaConsumerProperties
Resolves #3147
1 parent 04017cb commit 05237ea

File tree

1 file changed

+1
-17
lines changed
  • binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties

1 file changed

+1
-17
lines changed

binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java

Lines changed: 1 addition & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -210,15 +210,7 @@ public enum StandardHeaders {
210210
*/
211211
private boolean reactiveAtMostOnce;
212212

213-
/**
214-
* Consumer priority level. NOTE: Kafka does not natively support consumer priority.
215-
* This property is provided for consistency across binders but has no effect in Kafka.
216-
* For even message distribution across servers, use partition assignment strategies
217-
* or create separate bindings with concurrency=1.
218-
* Default: -1 (not supported)
219-
* @since 4.2
220-
*/
221-
private int consumerPriority = -1;
213+
222214

223215
/**
224216
* @return Container's ack mode.
@@ -496,12 +488,4 @@ public void setReactiveAtMostOnce(boolean reactiveAtMostOnce) {
496488
this.reactiveAtMostOnce = reactiveAtMostOnce;
497489
}
498490

499-
public int getConsumerPriority() {
500-
return this.consumerPriority;
501-
}
502-
503-
public void setConsumerPriority(int consumerPriority) {
504-
this.consumerPriority = consumerPriority;
505-
}
506-
507491
}

0 commit comments

Comments
 (0)