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

minor cleanup

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-08-08 20:59:05 +02:00
parent 688f05cbc9
commit ca0bfc028f
3 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java
View File

@@ -94,11 +94,7 @@ class KStreamBinder extends
@Override
protected Binding<KStream<Object, Object>> doBindConsumer(String name, String group,
KStream<Object, Object> inputTarget,
// @checkstyle:off
ExtendedConsumerProperties<KafkaStreamsConsumerProperties> properties) {
// @checkstyle:on
// this.kafkaStreamsBindingInformationCatalogue
// .registerConsumerProperties(inputTarget, properties.getExtension());
KStream<Object, Object> delegate = ((KStreamBoundElementFactory.KStreamWrapperHandler)
((Advised) inputTarget).getAdvisors()[0].getAdvice()).getDelegate();
@@ -120,9 +116,7 @@ class KStreamBinder extends
@SuppressWarnings("unchecked")
protected Binding<KStream<Object, Object>> doBindProducer(String name,
KStream<Object, Object> outboundBindTarget,
// @checkstyle:off
ExtendedProducerProperties<KafkaStreamsProducerProperties> properties) {
// @checkstyle:on
ExtendedProducerProperties<KafkaProducerProperties> extendedProducerProperties = new ExtendedProducerProperties<>(
new KafkaProducerProperties());
this.kafkaTopicProvisioner.provisionProducerDestination(name,

2
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java
View File

@@ -133,7 +133,7 @@ class KStreamBoundElementFactory extends AbstractBindingTargetFactory<KStream> {
}
}
public KStream<Object, Object> getDelegate() {
KStream<Object, Object> getDelegate() {
return delegate;
}
}

4
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java
View File

@@ -154,11 +154,11 @@ class KafkaStreamsBindingInformationCatalogue {
}
public Map<KStream<?, ?>, BindingProperties> getBindingProperties() {
Map<KStream<?, ?>, BindingProperties> getBindingProperties() {
return bindingProperties;
}
public Map<KStream<?, ?>, KafkaStreamsConsumerProperties> getConsumerProperties() {
Map<KStream<?, ?>, KafkaStreamsConsumerProperties> getConsumerProperties() {
return consumerProperties;
}
}