SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Setters for fields that need customization

Browse Source 
See this commit in core fore details:

442c72b37c
This commit is contained in:
Soby Chacko
2020-11-19 19:09:50 -05:00
committed by Gary Russell
parent 526627854a
commit fc184ba422
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -213,11 +213,11 @@ public class KafkaMessageChannelBinder extends
private final TransactionTemplate transactionTemplate;
private final KafkaBindingRebalanceListener rebalanceListener;
private KafkaBindingRebalanceListener rebalanceListener;
private final DlqPartitionFunction dlqPartitionFunction;
private DlqPartitionFunction dlqPartitionFunction;
private final DlqDestinationResolver dlqDestinationResolver;
private DlqDestinationResolver dlqDestinationResolver;
private final Map<ConsumerDestination, ContainerProperties.AckMode> ackModeInfo = new ConcurrentHashMap<>();
@@ -309,6 +309,18 @@ public class KafkaMessageChannelBinder extends
this.clientFactoryCustomizer = customizer;
}
public void setRebalanceListener(KafkaBindingRebalanceListener rebalanceListener) {
this.rebalanceListener = rebalanceListener;
}
public void setDlqPartitionFunction(DlqPartitionFunction dlqPartitionFunction) {
this.dlqPartitionFunction = dlqPartitionFunction;
}
public void setDlqDestinationResolver(DlqDestinationResolver dlqDestinationResolver) {
this.dlqDestinationResolver = dlqDestinationResolver;
}
Map<String, TopicInformation> getTopicsInUse() {
return this.topicsInUse;
}