From 03c143ad67658b8e6f1794b820a4d2e10726e53f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 28 Mar 2022 13:16:31 -0400 Subject: [PATCH] Kafka binder - mono repo for 3.2.x branch --- .gitignore => k-binder/.gitignore | 0 .jdk8 => k-binder/.jdk8 | 0 {.mvn => k-binder/.mvn}/jvm.config | 0 {.mvn => k-binder/.mvn}/maven.config | 0 .../.mvn}/wrapper/MavenWrapperDownloader.java | 0 {.mvn => k-binder/.mvn}/wrapper/maven-wrapper.jar | Bin .../.mvn}/wrapper/maven-wrapper.properties | 0 .settings.xml => k-binder/.settings.xml | 0 LICENSE => k-binder/LICENSE | 0 README.adoc => k-binder/README.adoc | 0 {docs => k-binder/docs}/.jdk8 | 0 {docs => k-binder/docs}/pom.xml | 0 .../docs}/src/main/asciidoc/.gitignore | 0 {docs => k-binder/docs}/src/main/asciidoc/Guardfile | 0 .../docs}/src/main/asciidoc/README.adoc | 0 .../docs}/src/main/asciidoc/_configprops.adoc | 0 .../docs}/src/main/asciidoc/appendix.adoc | 0 .../docs}/src/main/asciidoc/building.adoc | 0 .../docs}/src/main/asciidoc/contributing.adoc | 0 {docs => k-binder/docs}/src/main/asciidoc/dlq.adoc | 0 .../docs}/src/main/asciidoc/ghpages.sh | 0 .../docs}/src/main/asciidoc/images/kafka-binder.png | Bin .../asciidoc/images/kafka-streams-initializr.png | Bin .../images/spring-initializr-kafka-streams.png | Bin .../docs}/src/main/asciidoc/index-docinfo.xml | 0 .../docs}/src/main/asciidoc/kafka-streams.adoc | 0 .../docs}/src/main/asciidoc/overview.adoc | 0 .../docs}/src/main/asciidoc/partitions.adoc | 0 .../spring-cloud-stream-binder-kafka-aggregate.adoc | 0 .../asciidoc/spring-cloud-stream-binder-kafka.adoc | 0 {docs => k-binder/docs}/src/main/asciidoc/tips.adoc | 0 .../docs}/src/main/ruby/generate_readme.sh | 0 mvnw => k-binder/mvnw | 0 mvnw.cmd => k-binder/mvnw.cmd | 0 pom.xml => k-binder/pom.xml | 0 .../spring-cloud-starter-stream-kafka}/.jdk8 | 0 .../spring-cloud-starter-stream-kafka}/pom.xml | 0 .../spring-cloud-stream-binder-kafka-core}/.jdk8 | 0 .../.settings/org.eclipse.jdt.ui.prefs | 0 .../spring-cloud-stream-binder-kafka-core}/pom.xml | 0 .../properties/JaasLoginModuleConfiguration.java | 0 .../KafkaBinderConfigurationProperties.java | 0 .../kafka/properties/KafkaBindingProperties.java | 0 .../kafka/properties/KafkaConsumerProperties.java | 0 .../properties/KafkaExtendedBindingProperties.java | 0 .../kafka/properties/KafkaProducerProperties.java | 0 .../kafka/properties/KafkaTopicProperties.java | 0 .../provisioning/AdminClientConfigCustomizer.java | 0 .../kafka/provisioning/KafkaTopicProvisioner.java | 0 .../binder/kafka/utils/DlqDestinationResolver.java | 0 .../binder/kafka/utils/DlqPartitionFunction.java | 0 .../stream/binder/kafka/utils/KafkaTopicUtils.java | 0 .../KafkaBinderConfigurationPropertiesTest.java | 0 .../provisioning/KafkaTopicProvisionerTests.java | 0 .../src/test/resources/test.truststore.ks | Bin .../src/test/resources/testclient.keystore | 0 .../src/test/resources/testclient.truststore | 0 .../spring-cloud-stream-binder-kafka-streams}/.jdk8 | 0 .../pom.xml | 0 .../AbstractKafkaStreamsBinderProcessor.java | 0 .../streams/DeserializationExceptionHandler.java | 0 .../streams/EncodingDecodingBindAdviceHandler.java | 0 ...ingHandlerMappingsProviderAutoConfiguration.java | 0 .../binder/kafka/streams/GlobalKTableBinder.java | 0 .../streams/GlobalKTableBinderConfiguration.java | 0 .../streams/GlobalKTableBoundElementFactory.java | 0 .../kafka/streams/InteractiveQueryService.java | 0 .../stream/binder/kafka/streams/KStreamBinder.java | 0 .../kafka/streams/KStreamBinderConfiguration.java | 0 .../kafka/streams/KStreamBoundElementFactory.java | 0 .../KStreamStreamListenerParameterAdapter.java | 0 .../streams/KStreamStreamListenerResultAdapter.java | 0 .../stream/binder/kafka/streams/KTableBinder.java | 0 .../kafka/streams/KTableBinderConfiguration.java | 0 .../kafka/streams/KTableBoundElementFactory.java | 0 .../streams/KafkaStreamsBinderHealthIndicator.java | 0 ...kaStreamsBinderHealthIndicatorConfiguration.java | 0 .../kafka/streams/KafkaStreamsBinderMetrics.java | 0 .../KafkaStreamsBinderSupportAutoConfiguration.java | 0 .../kafka/streams/KafkaStreamsBinderUtils.java | 0 .../KafkaStreamsBindingInformationCatalogue.java | 0 .../streams/KafkaStreamsFunctionProcessor.java | 0 .../streams/KafkaStreamsJaasConfiguration.java | 0 .../KafkaStreamsMessageConversionDelegate.java | 0 .../binder/kafka/streams/KafkaStreamsRegistry.java | 0 ...treamsStreamListenerSetupMethodOrchestrator.java | 0 .../binder/kafka/streams/KeyValueSerdeResolver.java | 0 .../streams/MultiBinderPropertiesConfiguration.java | 0 .../binder/kafka/streams/SendToDlqAndContinue.java | 0 .../streams/SkipAndContinueExceptionHandler.java | 0 .../kafka/streams/StreamsBuilderFactoryManager.java | 0 .../streams/annotations/KafkaStreamsProcessor.java | 0 .../streams/annotations/KafkaStreamsStateStore.java | 0 .../endpoint/KafkaStreamsTopologyEndpoint.java | 0 ...fkaStreamsTopologyEndpointAutoConfiguration.java | 0 .../streams/function/FunctionDetectorCondition.java | 0 .../function/KafkaStreamsBindableProxyFactory.java | 0 .../KafkaStreamsFunctionAutoConfiguration.java | 0 .../KafkaStreamsFunctionBeanPostProcessor.java | 0 .../KafkaStreamsFunctionProcessorInvoker.java | 0 .../KafkaStreamsBinderConfigurationProperties.java | 0 .../properties/KafkaStreamsBindingProperties.java | 0 .../properties/KafkaStreamsConsumerProperties.java | 0 .../KafkaStreamsExtendedBindingProperties.java | 0 .../properties/KafkaStreamsProducerProperties.java | 0 .../KafkaStreamsStateStoreProperties.java | 0 .../binder/kafka/streams/serde/CollectionSerde.java | 0 .../streams/serde/CompositeNonNativeSerde.java | 0 .../serde/MessageConverterDelegateSerde.java | 0 .../src/main/resources/META-INF/spring.binders | 0 .../src/main/resources/META-INF/spring.factories | 0 ...ndlerMappingsProviderAutoConfigurationTests.java | 0 .../streams/KafkaStreamsEventTypeRoutingTests.java | 0 .../KafkaStreamsFunctionCompositionTests.java | 0 ...afkaStreamsInteractiveQueryIntegrationTests.java | 0 .../streams/MultipleFunctionsInSameAppTests.java | 0 .../bootstrap/KafkaStreamsBinderBootstrapTest.java | 0 .../bootstrap/KafkaStreamsBinderJaasInitTests.java | 0 ...StreamsBinderWordCountBranchesFunctionTests.java | 0 .../KafkaStreamsBinderWordCountFunctionTests.java | 0 .../function/KafkaStreamsComponentBeansTests.java | 0 .../KafkaStreamsFunctionStateStoreTests.java | 0 .../streams/function/KafkaStreamsRetryTests.java | 0 .../function/SerdesProvidedAsBeansTests.java | 0 .../function/StreamToGlobalKTableFunctionTests.java | 0 .../function/StreamToTableJoinFunctionTests.java | 0 .../DeserializationErrorHandlerByKafkaTests.java | 0 .../DeserializtionErrorHandlerByBinderTests.java | 0 .../integration/DlqDestinationResolverTests.java | 0 ...KafkaStreamsBinderDestinationIsPatternTests.java | 0 .../KafkaStreamsBinderHealthIndicatorTests.java | 0 .../KafkaStreamsBinderMultipleInputTopicsTest.java | 0 ...sBinderPojoInputAndPrimitiveTypeOutputTests.java | 0 .../KafkaStreamsBinderTombstoneTests.java | 0 .../KafkaStreamsNativeEncodingDecodingTests.java | 0 .../KafkaStreamsStateStoreIntegrationTests.java | 0 ...BinderPojoInputStringOutputIntegrationTests.java | 0 .../MultiProcessorsWithSameNameAndBindingTests.java | 0 .../integration/PerRecordAvroContentTypeTests.java | 0 .../integration/utils/TestAvroSerializer.java | 0 .../kafka/streams/serde/CollectionSerdeTest.java | 0 .../src/test/resources/avro/sensor.avsc | 0 .../src/test/resources/logback.xml | 0 .../stream/binder/kstream/integTest-1.properties | 0 .../spring-cloud-stream-binder-kafka}/.jdk8 | 0 .../.settings/org.eclipse.jdt.ui.prefs | 0 .../spring-cloud-stream-binder-kafka}/pom.xml | 0 .../stream/binder/kafka/BinderHeaderMapper.java | 0 .../kafka/KafkaBinderEnvironmentPostProcessor.java | 0 .../stream/binder/kafka/KafkaBinderHealth.java | 0 .../binder/kafka/KafkaBinderHealthIndicator.java | 0 .../stream/binder/kafka/KafkaBinderMetrics.java | 0 .../binder/kafka/KafkaBindingRebalanceListener.java | 0 .../kafka/KafkaExpressionEvaluatingInterceptor.java | 0 .../binder/kafka/KafkaMessageChannelBinder.java | 0 .../stream/binder/kafka/KafkaNullConverter.java | 0 .../ListenerContainerWithDlqAndRetryCustomizer.java | 0 .../kafka/config/ClientFactoryCustomizer.java | 0 .../kafka/config/ConsumerConfigCustomizer.java | 0 ...BindingHandlerMappingsProviderConfiguration.java | 0 .../kafka/config/KafkaBinderConfiguration.java | 0 .../KafkaBinderHealthIndicatorConfiguration.java | 0 .../kafka/config/ProducerConfigCustomizer.java | 0 .../src/main/resources/META-INF/spring.binders | 0 .../src/main/resources/META-INF/spring.factories | 0 .../binder/kafka/AbstractKafkaTestBinder.java | 0 .../cloud/stream/binder/kafka/AdminConfigTests.java | 0 .../binder/kafka/AutoCreateTopicDisabledTests.java | 0 .../KafkaBinderAutoConfigurationPropertiesTest.java | 0 .../KafkaBinderConfigurationPropertiesTest.java | 0 .../binder/kafka/KafkaBinderConfigurationTest.java | 0 .../kafka/KafkaBinderHealthIndicatorTest.java | 0 .../KafkaBinderJaasInitializerListenerTest.java | 0 .../stream/binder/kafka/KafkaBinderMetricsTest.java | 0 .../cloud/stream/binder/kafka/KafkaBinderTests.java | 0 .../stream/binder/kafka/KafkaBinderUnitTests.java | 0 .../cloud/stream/binder/kafka/KafkaTestBinder.java | 0 .../stream/binder/kafka/KafkaTransactionTests.java | 0 .../binder/kafka/RawKafkaPartitionTestSupport.java | 0 .../stream/binder/kafka/TestKafkaProperties.java | 0 .../kafka/bootstrap/KafkaBinderBootstrapTest.java | 0 .../KafkaBinderCustomHealthCheckTests.java | 0 .../bootstrap/KafkaBinderMeterRegistryTest.java | 0 .../kafka/integration/KafkaBinderActuatorTests.java | 0 .../KafkaBinderExtendedPropertiesTest.java | 0 .../integration/KafkaConfigCustomizationTests.java | 0 .../kafka/integration/KafkaNullConverterTest.java | 0 .../KafkaRetryDlqBinderOrContainerTests.java | 0 .../integration/ProducerOnlyTransactionTests.java | 0 .../BaseKafkaBinderTopicPropertiesUpdateTest.java | 0 ...isabledKafkaBinderTopicPropertiesUpdateTest.java | 0 .../KafkaBinderTopicPropertiesUpdateTest.java | 0 .../ConsumerProducerTransactionTests.java | 0 .../resources/binder-config-autoconfig.properties | 0 .../src/test/resources/binder-config.properties | 0 .../src/test/resources/jaas-sample-kafka-only.conf | 0 .../src/test/resources/jaas-sample-with-zk.conf | 0 .../src/test/resources/logback.xml | 0 update-version.sh => k-binder/update-version.sh | 0 199 files changed, 0 insertions(+), 0 deletions(-) rename .gitignore => k-binder/.gitignore (100%) rename .jdk8 => k-binder/.jdk8 (100%) rename {.mvn => k-binder/.mvn}/jvm.config (100%) rename {.mvn => k-binder/.mvn}/maven.config (100%) rename {.mvn => k-binder/.mvn}/wrapper/MavenWrapperDownloader.java (100%) rename {.mvn => k-binder/.mvn}/wrapper/maven-wrapper.jar (100%) rename {.mvn => k-binder/.mvn}/wrapper/maven-wrapper.properties (100%) rename .settings.xml => k-binder/.settings.xml (100%) rename LICENSE => k-binder/LICENSE (100%) rename README.adoc => k-binder/README.adoc (100%) rename {docs => k-binder/docs}/.jdk8 (100%) rename {docs => k-binder/docs}/pom.xml (100%) rename {docs => k-binder/docs}/src/main/asciidoc/.gitignore (100%) rename {docs => k-binder/docs}/src/main/asciidoc/Guardfile (100%) rename {docs => k-binder/docs}/src/main/asciidoc/README.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/_configprops.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/appendix.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/building.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/contributing.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/dlq.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/ghpages.sh (100%) rename {docs => k-binder/docs}/src/main/asciidoc/images/kafka-binder.png (100%) rename {docs => k-binder/docs}/src/main/asciidoc/images/kafka-streams-initializr.png (100%) rename {docs => k-binder/docs}/src/main/asciidoc/images/spring-initializr-kafka-streams.png (100%) rename {docs => k-binder/docs}/src/main/asciidoc/index-docinfo.xml (100%) rename {docs => k-binder/docs}/src/main/asciidoc/kafka-streams.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/overview.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/partitions.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/spring-cloud-stream-binder-kafka-aggregate.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/spring-cloud-stream-binder-kafka.adoc (100%) rename {docs => k-binder/docs}/src/main/asciidoc/tips.adoc (100%) rename {docs => k-binder/docs}/src/main/ruby/generate_readme.sh (100%) rename mvnw => k-binder/mvnw (100%) rename mvnw.cmd => k-binder/mvnw.cmd (100%) rename pom.xml => k-binder/pom.xml (100%) rename {spring-cloud-starter-stream-kafka => k-binder/spring-cloud-starter-stream-kafka}/.jdk8 (100%) rename {spring-cloud-starter-stream-kafka => k-binder/spring-cloud-starter-stream-kafka}/pom.xml (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/.jdk8 (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/.settings/org.eclipse.jdt.ui.prefs (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/pom.xml (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/JaasLoginModuleConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBindingProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaTopicProperties.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/AdminClientConfigCustomizer.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqDestinationResolver.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqPartitionFunction.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/test/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisionerTests.java (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/test/resources/test.truststore.ks (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/test/resources/testclient.keystore (100%) rename {spring-cloud-stream-binder-kafka-core => k-binder/spring-cloud-stream-binder-kafka-core}/src/test/resources/testclient.truststore (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/.jdk8 (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/pom.xml (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DeserializationExceptionHandler.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/EncodingDecodingBindAdviceHandler.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinder.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinderConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBoundElementFactory.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinderConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerParameterAdapter.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerResultAdapter.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinder.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinderConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBoundElementFactory.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsJaasConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsStreamListenerSetupMethodOrchestrator.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/MultiBinderPropertiesConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SendToDlqAndContinue.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SkipAndContinueExceptionHandler.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsProcessor.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsStateStore.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpoint.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpointAutoConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionAutoConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionProcessorInvoker.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBinderConfigurationProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBindingProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsConsumerProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsProducerProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsStateStoreProperties.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/MessageConverterDelegateSerde.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/resources/META-INF/spring.binders (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/main/resources/META-INF/spring.factories (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsInteractiveQueryIntegrationTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/MultipleFunctionsInSameAppTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/SerdesProvidedAsBeansTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializationErrorHandlerByKafkaTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializtionErrorHandlerByBinderTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderHealthIndicatorTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameAndBindingTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/PerRecordAvroContentTypeTests.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/utils/TestAvroSerializer.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/resources/avro/sensor.avsc (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/resources/logback.xml (100%) rename {spring-cloud-stream-binder-kafka-streams => k-binder/spring-cloud-stream-binder-kafka-streams}/src/test/resources/org/springframework/cloud/stream/binder/kstream/integTest-1.properties (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/.jdk8 (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/.settings/org.eclipse.jdt.ui.prefs (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/pom.xml (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealth.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBindingRebalanceListener.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaExpressionEvaluatingInterceptor.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ClientFactoryCustomizer.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ConsumerConfigCustomizer.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ExtendedBindingHandlerMappingsProviderConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ProducerConfigCustomizer.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/resources/META-INF/spring.binders (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/main/resources/META-INF/spring.factories (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/AbstractKafkaTestBinder.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/AdminConfigTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/AutoCreateTopicDisabledTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderAutoConfigurationPropertiesTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationPropertiesTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicatorTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderJaasInitializerListenerTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetricsTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/RawKafkaPartitionTestSupport.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaProperties.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderBootstrapTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderCustomHealthCheckTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderMeterRegistryTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaNullConverterTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaRetryDlqBinderOrContainerTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/ProducerOnlyTransactionTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/BaseKafkaBinderTopicPropertiesUpdateTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/DisabledKafkaBinderTopicPropertiesUpdateTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/KafkaBinderTopicPropertiesUpdateTest.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/resources/binder-config-autoconfig.properties (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/resources/binder-config.properties (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/resources/jaas-sample-kafka-only.conf (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/resources/jaas-sample-with-zk.conf (100%) rename {spring-cloud-stream-binder-kafka => k-binder/spring-cloud-stream-binder-kafka}/src/test/resources/logback.xml (100%) rename update-version.sh => k-binder/update-version.sh (100%) diff --git a/.gitignore b/k-binder/.gitignore similarity index 100% rename from .gitignore rename to k-binder/.gitignore diff --git a/.jdk8 b/k-binder/.jdk8 similarity index 100% rename from .jdk8 rename to k-binder/.jdk8 diff --git a/.mvn/jvm.config b/k-binder/.mvn/jvm.config similarity index 100% rename from .mvn/jvm.config rename to k-binder/.mvn/jvm.config diff --git a/.mvn/maven.config b/k-binder/.mvn/maven.config similarity index 100% rename from .mvn/maven.config rename to k-binder/.mvn/maven.config diff --git a/.mvn/wrapper/MavenWrapperDownloader.java b/k-binder/.mvn/wrapper/MavenWrapperDownloader.java similarity index 100% rename from .mvn/wrapper/MavenWrapperDownloader.java rename to k-binder/.mvn/wrapper/MavenWrapperDownloader.java diff --git a/.mvn/wrapper/maven-wrapper.jar b/k-binder/.mvn/wrapper/maven-wrapper.jar similarity index 100% rename from .mvn/wrapper/maven-wrapper.jar rename to k-binder/.mvn/wrapper/maven-wrapper.jar diff --git a/.mvn/wrapper/maven-wrapper.properties b/k-binder/.mvn/wrapper/maven-wrapper.properties similarity index 100% rename from .mvn/wrapper/maven-wrapper.properties rename to k-binder/.mvn/wrapper/maven-wrapper.properties diff --git a/.settings.xml b/k-binder/.settings.xml similarity index 100% rename from .settings.xml rename to k-binder/.settings.xml diff --git a/LICENSE b/k-binder/LICENSE similarity index 100% rename from LICENSE rename to k-binder/LICENSE diff --git a/README.adoc b/k-binder/README.adoc similarity index 100% rename from README.adoc rename to k-binder/README.adoc diff --git a/docs/.jdk8 b/k-binder/docs/.jdk8 similarity index 100% rename from docs/.jdk8 rename to k-binder/docs/.jdk8 diff --git a/docs/pom.xml b/k-binder/docs/pom.xml similarity index 100% rename from docs/pom.xml rename to k-binder/docs/pom.xml diff --git a/docs/src/main/asciidoc/.gitignore b/k-binder/docs/src/main/asciidoc/.gitignore similarity index 100% rename from docs/src/main/asciidoc/.gitignore rename to k-binder/docs/src/main/asciidoc/.gitignore diff --git a/docs/src/main/asciidoc/Guardfile b/k-binder/docs/src/main/asciidoc/Guardfile similarity index 100% rename from docs/src/main/asciidoc/Guardfile rename to k-binder/docs/src/main/asciidoc/Guardfile diff --git a/docs/src/main/asciidoc/README.adoc b/k-binder/docs/src/main/asciidoc/README.adoc similarity index 100% rename from docs/src/main/asciidoc/README.adoc rename to k-binder/docs/src/main/asciidoc/README.adoc diff --git a/docs/src/main/asciidoc/_configprops.adoc b/k-binder/docs/src/main/asciidoc/_configprops.adoc similarity index 100% rename from docs/src/main/asciidoc/_configprops.adoc rename to k-binder/docs/src/main/asciidoc/_configprops.adoc diff --git a/docs/src/main/asciidoc/appendix.adoc b/k-binder/docs/src/main/asciidoc/appendix.adoc similarity index 100% rename from docs/src/main/asciidoc/appendix.adoc rename to k-binder/docs/src/main/asciidoc/appendix.adoc diff --git a/docs/src/main/asciidoc/building.adoc b/k-binder/docs/src/main/asciidoc/building.adoc similarity index 100% rename from docs/src/main/asciidoc/building.adoc rename to k-binder/docs/src/main/asciidoc/building.adoc diff --git a/docs/src/main/asciidoc/contributing.adoc b/k-binder/docs/src/main/asciidoc/contributing.adoc similarity index 100% rename from docs/src/main/asciidoc/contributing.adoc rename to k-binder/docs/src/main/asciidoc/contributing.adoc diff --git a/docs/src/main/asciidoc/dlq.adoc b/k-binder/docs/src/main/asciidoc/dlq.adoc similarity index 100% rename from docs/src/main/asciidoc/dlq.adoc rename to k-binder/docs/src/main/asciidoc/dlq.adoc diff --git a/docs/src/main/asciidoc/ghpages.sh b/k-binder/docs/src/main/asciidoc/ghpages.sh similarity index 100% rename from docs/src/main/asciidoc/ghpages.sh rename to k-binder/docs/src/main/asciidoc/ghpages.sh diff --git a/docs/src/main/asciidoc/images/kafka-binder.png b/k-binder/docs/src/main/asciidoc/images/kafka-binder.png similarity index 100% rename from docs/src/main/asciidoc/images/kafka-binder.png rename to k-binder/docs/src/main/asciidoc/images/kafka-binder.png diff --git a/docs/src/main/asciidoc/images/kafka-streams-initializr.png b/k-binder/docs/src/main/asciidoc/images/kafka-streams-initializr.png similarity index 100% rename from docs/src/main/asciidoc/images/kafka-streams-initializr.png rename to k-binder/docs/src/main/asciidoc/images/kafka-streams-initializr.png diff --git a/docs/src/main/asciidoc/images/spring-initializr-kafka-streams.png b/k-binder/docs/src/main/asciidoc/images/spring-initializr-kafka-streams.png similarity index 100% rename from docs/src/main/asciidoc/images/spring-initializr-kafka-streams.png rename to k-binder/docs/src/main/asciidoc/images/spring-initializr-kafka-streams.png diff --git a/docs/src/main/asciidoc/index-docinfo.xml b/k-binder/docs/src/main/asciidoc/index-docinfo.xml similarity index 100% rename from docs/src/main/asciidoc/index-docinfo.xml rename to k-binder/docs/src/main/asciidoc/index-docinfo.xml diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/k-binder/docs/src/main/asciidoc/kafka-streams.adoc similarity index 100% rename from docs/src/main/asciidoc/kafka-streams.adoc rename to k-binder/docs/src/main/asciidoc/kafka-streams.adoc diff --git a/docs/src/main/asciidoc/overview.adoc b/k-binder/docs/src/main/asciidoc/overview.adoc similarity index 100% rename from docs/src/main/asciidoc/overview.adoc rename to k-binder/docs/src/main/asciidoc/overview.adoc diff --git a/docs/src/main/asciidoc/partitions.adoc b/k-binder/docs/src/main/asciidoc/partitions.adoc similarity index 100% rename from docs/src/main/asciidoc/partitions.adoc rename to k-binder/docs/src/main/asciidoc/partitions.adoc diff --git a/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka-aggregate.adoc b/k-binder/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka-aggregate.adoc similarity index 100% rename from docs/src/main/asciidoc/spring-cloud-stream-binder-kafka-aggregate.adoc rename to k-binder/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka-aggregate.adoc diff --git a/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka.adoc b/k-binder/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka.adoc similarity index 100% rename from docs/src/main/asciidoc/spring-cloud-stream-binder-kafka.adoc rename to k-binder/docs/src/main/asciidoc/spring-cloud-stream-binder-kafka.adoc diff --git a/docs/src/main/asciidoc/tips.adoc b/k-binder/docs/src/main/asciidoc/tips.adoc similarity index 100% rename from docs/src/main/asciidoc/tips.adoc rename to k-binder/docs/src/main/asciidoc/tips.adoc diff --git a/docs/src/main/ruby/generate_readme.sh b/k-binder/docs/src/main/ruby/generate_readme.sh similarity index 100% rename from docs/src/main/ruby/generate_readme.sh rename to k-binder/docs/src/main/ruby/generate_readme.sh diff --git a/mvnw b/k-binder/mvnw similarity index 100% rename from mvnw rename to k-binder/mvnw diff --git a/mvnw.cmd b/k-binder/mvnw.cmd similarity index 100% rename from mvnw.cmd rename to k-binder/mvnw.cmd diff --git a/pom.xml b/k-binder/pom.xml similarity index 100% rename from pom.xml rename to k-binder/pom.xml diff --git a/spring-cloud-starter-stream-kafka/.jdk8 b/k-binder/spring-cloud-starter-stream-kafka/.jdk8 similarity index 100% rename from spring-cloud-starter-stream-kafka/.jdk8 rename to k-binder/spring-cloud-starter-stream-kafka/.jdk8 diff --git a/spring-cloud-starter-stream-kafka/pom.xml b/k-binder/spring-cloud-starter-stream-kafka/pom.xml similarity index 100% rename from spring-cloud-starter-stream-kafka/pom.xml rename to k-binder/spring-cloud-starter-stream-kafka/pom.xml diff --git a/spring-cloud-stream-binder-kafka-core/.jdk8 b/k-binder/spring-cloud-stream-binder-kafka-core/.jdk8 similarity index 100% rename from spring-cloud-stream-binder-kafka-core/.jdk8 rename to k-binder/spring-cloud-stream-binder-kafka-core/.jdk8 diff --git a/spring-cloud-stream-binder-kafka-core/.settings/org.eclipse.jdt.ui.prefs b/k-binder/spring-cloud-stream-binder-kafka-core/.settings/org.eclipse.jdt.ui.prefs similarity index 100% rename from spring-cloud-stream-binder-kafka-core/.settings/org.eclipse.jdt.ui.prefs rename to k-binder/spring-cloud-stream-binder-kafka-core/.settings/org.eclipse.jdt.ui.prefs diff --git a/spring-cloud-stream-binder-kafka-core/pom.xml b/k-binder/spring-cloud-stream-binder-kafka-core/pom.xml similarity index 100% rename from spring-cloud-stream-binder-kafka-core/pom.xml rename to k-binder/spring-cloud-stream-binder-kafka-core/pom.xml diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/JaasLoginModuleConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/JaasLoginModuleConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/JaasLoginModuleConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/JaasLoginModuleConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBindingProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBindingProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBindingProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBindingProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaConsumerProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaTopicProperties.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaTopicProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaTopicProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaTopicProperties.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/AdminClientConfigCustomizer.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/AdminClientConfigCustomizer.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/AdminClientConfigCustomizer.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/AdminClientConfigCustomizer.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqDestinationResolver.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqDestinationResolver.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqDestinationResolver.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqDestinationResolver.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqPartitionFunction.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqPartitionFunction.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqPartitionFunction.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/DlqPartitionFunction.java diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java diff --git a/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java diff --git a/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisionerTests.java b/k-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisionerTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisionerTests.java rename to k-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisionerTests.java diff --git a/spring-cloud-stream-binder-kafka-core/src/test/resources/test.truststore.ks b/k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/test.truststore.ks similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/test/resources/test.truststore.ks rename to k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/test.truststore.ks diff --git a/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.keystore b/k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.keystore similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.keystore rename to k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.keystore diff --git a/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.truststore b/k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.truststore similarity index 100% rename from spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.truststore rename to k-binder/spring-cloud-stream-binder-kafka-core/src/test/resources/testclient.truststore diff --git a/spring-cloud-stream-binder-kafka-streams/.jdk8 b/k-binder/spring-cloud-stream-binder-kafka-streams/.jdk8 similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/.jdk8 rename to k-binder/spring-cloud-stream-binder-kafka-streams/.jdk8 diff --git a/spring-cloud-stream-binder-kafka-streams/pom.xml b/k-binder/spring-cloud-stream-binder-kafka-streams/pom.xml similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/pom.xml rename to k-binder/spring-cloud-stream-binder-kafka-streams/pom.xml diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DeserializationExceptionHandler.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DeserializationExceptionHandler.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DeserializationExceptionHandler.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DeserializationExceptionHandler.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/EncodingDecodingBindAdviceHandler.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/EncodingDecodingBindAdviceHandler.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/EncodingDecodingBindAdviceHandler.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/EncodingDecodingBindAdviceHandler.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinder.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinder.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinder.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinderConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinderConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinderConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBinderConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBoundElementFactory.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBoundElementFactory.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBoundElementFactory.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/GlobalKTableBoundElementFactory.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinderConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinderConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinderConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinderConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBoundElementFactory.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerParameterAdapter.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerParameterAdapter.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerParameterAdapter.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerParameterAdapter.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerResultAdapter.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerResultAdapter.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerResultAdapter.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamStreamListenerResultAdapter.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinder.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinder.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinder.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinderConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinderConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinderConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBinderConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBoundElementFactory.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBoundElementFactory.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBoundElementFactory.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KTableBoundElementFactory.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBindingInformationCatalogue.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsJaasConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsJaasConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsJaasConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsJaasConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsStreamListenerSetupMethodOrchestrator.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsStreamListenerSetupMethodOrchestrator.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsStreamListenerSetupMethodOrchestrator.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsStreamListenerSetupMethodOrchestrator.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/MultiBinderPropertiesConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/MultiBinderPropertiesConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/MultiBinderPropertiesConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/MultiBinderPropertiesConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SendToDlqAndContinue.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SendToDlqAndContinue.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SendToDlqAndContinue.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SendToDlqAndContinue.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SkipAndContinueExceptionHandler.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SkipAndContinueExceptionHandler.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SkipAndContinueExceptionHandler.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/SkipAndContinueExceptionHandler.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsProcessor.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsProcessor.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsProcessor.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsProcessor.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsStateStore.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsStateStore.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsStateStore.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/annotations/KafkaStreamsStateStore.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpoint.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpoint.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpoint.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpoint.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpointAutoConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpointAutoConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpointAutoConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/endpoint/KafkaStreamsTopologyEndpointAutoConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionAutoConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionAutoConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionAutoConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionAutoConfiguration.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionProcessorInvoker.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionProcessorInvoker.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionProcessorInvoker.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionProcessorInvoker.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBinderConfigurationProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBinderConfigurationProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBinderConfigurationProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBinderConfigurationProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBindingProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBindingProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBindingProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsBindingProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsConsumerProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsConsumerProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsConsumerProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsConsumerProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsProducerProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsProducerProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsProducerProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsProducerProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsStateStoreProperties.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsStateStoreProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsStateStoreProperties.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsStateStoreProperties.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/MessageConverterDelegateSerde.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/MessageConverterDelegateSerde.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/MessageConverterDelegateSerde.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/MessageConverterDelegateSerde.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.binders b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.binders similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.binders rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.binders diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.factories b/k-binder/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.factories similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.factories rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/main/resources/META-INF/spring.factories diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsInteractiveQueryIntegrationTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsInteractiveQueryIntegrationTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsInteractiveQueryIntegrationTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsInteractiveQueryIntegrationTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/MultipleFunctionsInSameAppTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/MultipleFunctionsInSameAppTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/MultipleFunctionsInSameAppTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/MultipleFunctionsInSameAppTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/SerdesProvidedAsBeansTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/SerdesProvidedAsBeansTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/SerdesProvidedAsBeansTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/SerdesProvidedAsBeansTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializationErrorHandlerByKafkaTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializationErrorHandlerByKafkaTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializationErrorHandlerByKafkaTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializationErrorHandlerByKafkaTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializtionErrorHandlerByBinderTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializtionErrorHandlerByBinderTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializtionErrorHandlerByBinderTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DeserializtionErrorHandlerByBinderTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderHealthIndicatorTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderHealthIndicatorTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderHealthIndicatorTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderHealthIndicatorTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameAndBindingTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameAndBindingTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameAndBindingTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameAndBindingTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/PerRecordAvroContentTypeTests.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/PerRecordAvroContentTypeTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/PerRecordAvroContentTypeTests.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/PerRecordAvroContentTypeTests.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/utils/TestAvroSerializer.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/utils/TestAvroSerializer.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/utils/TestAvroSerializer.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/utils/TestAvroSerializer.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/resources/avro/sensor.avsc b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/avro/sensor.avsc similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/resources/avro/sensor.avsc rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/avro/sensor.avsc diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/resources/logback.xml b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/logback.xml similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/resources/logback.xml rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/logback.xml diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/resources/org/springframework/cloud/stream/binder/kstream/integTest-1.properties b/k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/org/springframework/cloud/stream/binder/kstream/integTest-1.properties similarity index 100% rename from spring-cloud-stream-binder-kafka-streams/src/test/resources/org/springframework/cloud/stream/binder/kstream/integTest-1.properties rename to k-binder/spring-cloud-stream-binder-kafka-streams/src/test/resources/org/springframework/cloud/stream/binder/kstream/integTest-1.properties diff --git a/spring-cloud-stream-binder-kafka/.jdk8 b/k-binder/spring-cloud-stream-binder-kafka/.jdk8 similarity index 100% rename from spring-cloud-stream-binder-kafka/.jdk8 rename to k-binder/spring-cloud-stream-binder-kafka/.jdk8 diff --git a/spring-cloud-stream-binder-kafka/.settings/org.eclipse.jdt.ui.prefs b/k-binder/spring-cloud-stream-binder-kafka/.settings/org.eclipse.jdt.ui.prefs similarity index 100% rename from spring-cloud-stream-binder-kafka/.settings/org.eclipse.jdt.ui.prefs rename to k-binder/spring-cloud-stream-binder-kafka/.settings/org.eclipse.jdt.ui.prefs diff --git a/spring-cloud-stream-binder-kafka/pom.xml b/k-binder/spring-cloud-stream-binder-kafka/pom.xml similarity index 100% rename from spring-cloud-stream-binder-kafka/pom.xml rename to k-binder/spring-cloud-stream-binder-kafka/pom.xml diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealth.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealth.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealth.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealth.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBindingRebalanceListener.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBindingRebalanceListener.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBindingRebalanceListener.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBindingRebalanceListener.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaExpressionEvaluatingInterceptor.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaExpressionEvaluatingInterceptor.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaExpressionEvaluatingInterceptor.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaExpressionEvaluatingInterceptor.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaNullConverter.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ClientFactoryCustomizer.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ClientFactoryCustomizer.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ClientFactoryCustomizer.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ClientFactoryCustomizer.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ConsumerConfigCustomizer.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ConsumerConfigCustomizer.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ConsumerConfigCustomizer.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ConsumerConfigCustomizer.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ExtendedBindingHandlerMappingsProviderConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ExtendedBindingHandlerMappingsProviderConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ExtendedBindingHandlerMappingsProviderConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ExtendedBindingHandlerMappingsProviderConfiguration.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ProducerConfigCustomizer.java b/k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ProducerConfigCustomizer.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ProducerConfigCustomizer.java rename to k-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/ProducerConfigCustomizer.java diff --git a/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.binders b/k-binder/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.binders similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.binders rename to k-binder/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.binders diff --git a/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.factories b/k-binder/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.factories similarity index 100% rename from spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.factories rename to k-binder/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring.factories diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AbstractKafkaTestBinder.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AbstractKafkaTestBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AbstractKafkaTestBinder.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AbstractKafkaTestBinder.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AdminConfigTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AdminConfigTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AdminConfigTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AdminConfigTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AutoCreateTopicDisabledTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AutoCreateTopicDisabledTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AutoCreateTopicDisabledTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/AutoCreateTopicDisabledTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderAutoConfigurationPropertiesTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderAutoConfigurationPropertiesTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderAutoConfigurationPropertiesTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderAutoConfigurationPropertiesTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationPropertiesTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationPropertiesTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationPropertiesTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationPropertiesTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderConfigurationTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicatorTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicatorTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicatorTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicatorTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderJaasInitializerListenerTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderJaasInitializerListenerTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderJaasInitializerListenerTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderJaasInitializerListenerTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetricsTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetricsTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetricsTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetricsTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawKafkaPartitionTestSupport.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawKafkaPartitionTestSupport.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawKafkaPartitionTestSupport.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawKafkaPartitionTestSupport.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaProperties.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaProperties.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaProperties.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaProperties.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderBootstrapTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderBootstrapTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderBootstrapTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderBootstrapTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderCustomHealthCheckTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderCustomHealthCheckTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderCustomHealthCheckTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderCustomHealthCheckTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderMeterRegistryTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderMeterRegistryTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderMeterRegistryTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/bootstrap/KafkaBinderMeterRegistryTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaNullConverterTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaNullConverterTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaNullConverterTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaNullConverterTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaRetryDlqBinderOrContainerTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaRetryDlqBinderOrContainerTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaRetryDlqBinderOrContainerTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaRetryDlqBinderOrContainerTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/ProducerOnlyTransactionTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/ProducerOnlyTransactionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/ProducerOnlyTransactionTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/ProducerOnlyTransactionTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/BaseKafkaBinderTopicPropertiesUpdateTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/BaseKafkaBinderTopicPropertiesUpdateTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/BaseKafkaBinderTopicPropertiesUpdateTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/BaseKafkaBinderTopicPropertiesUpdateTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/DisabledKafkaBinderTopicPropertiesUpdateTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/DisabledKafkaBinderTopicPropertiesUpdateTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/DisabledKafkaBinderTopicPropertiesUpdateTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/DisabledKafkaBinderTopicPropertiesUpdateTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/KafkaBinderTopicPropertiesUpdateTest.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/KafkaBinderTopicPropertiesUpdateTest.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/KafkaBinderTopicPropertiesUpdateTest.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/topic/configs/KafkaBinderTopicPropertiesUpdateTest.java diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java b/k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java rename to k-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java diff --git a/spring-cloud-stream-binder-kafka/src/test/resources/binder-config-autoconfig.properties b/k-binder/spring-cloud-stream-binder-kafka/src/test/resources/binder-config-autoconfig.properties similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/resources/binder-config-autoconfig.properties rename to k-binder/spring-cloud-stream-binder-kafka/src/test/resources/binder-config-autoconfig.properties diff --git a/spring-cloud-stream-binder-kafka/src/test/resources/binder-config.properties b/k-binder/spring-cloud-stream-binder-kafka/src/test/resources/binder-config.properties similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/resources/binder-config.properties rename to k-binder/spring-cloud-stream-binder-kafka/src/test/resources/binder-config.properties diff --git a/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-kafka-only.conf b/k-binder/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-kafka-only.conf similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-kafka-only.conf rename to k-binder/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-kafka-only.conf diff --git a/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-with-zk.conf b/k-binder/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-with-zk.conf similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-with-zk.conf rename to k-binder/spring-cloud-stream-binder-kafka/src/test/resources/jaas-sample-with-zk.conf diff --git a/spring-cloud-stream-binder-kafka/src/test/resources/logback.xml b/k-binder/spring-cloud-stream-binder-kafka/src/test/resources/logback.xml similarity index 100% rename from spring-cloud-stream-binder-kafka/src/test/resources/logback.xml rename to k-binder/spring-cloud-stream-binder-kafka/src/test/resources/logback.xml diff --git a/update-version.sh b/k-binder/update-version.sh similarity index 100% rename from update-version.sh rename to k-binder/update-version.sh