From ca0bfc028f9547afc9b91a6eb2c8fec85ee3facb Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@pivotal.io>
Date: Thu, 8 Aug 2019 20:59:05 +0200
Subject: [PATCH] minor cleanup

---
 .../cloud/stream/binder/kafka/streams/KStreamBinder.java    | 6 ------
 .../binder/kafka/streams/KStreamBoundElementFactory.java    | 2 +-
 .../streams/KafkaStreamsBindingInformationCatalogue.java    | 4 ++--
 3 files changed, 3 insertions(+), 9 deletions(-)

diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java
index 197a6358b..caa661567 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java
@@ -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,
diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java
index a14436113..439d935ef 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java
@@ -133,7 +133,7 @@ class KStreamBoundElementFactory extends AbstractBindingTargetFactory<KStream> {
 			}
 		}
 
-		public KStream<Object, Object> getDelegate() {
+		KStream<Object, Object> getDelegate() {
 			return delegate;
 		}
 	}
diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java
index d055bb0ac..56d91c64a 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java
@@ -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;
 	}
 }