clean code

.github/workflows/boot-reactor-consumer.yml

@@ -0,0 +1,33 @@
+name: boot-kafka-reactor-consumer
+
+on:
+ push:
+ paths:
+ - "kafka-reactor/boot-kafka-reactor-consumer/**"
+ branches: [ master ]
+ pull_request:
+ paths:
+ - "kafka-reactor/boot-kafka-reactor-consumer/**"
+ types:
+ - opened
+ - synchronize
+ - reopened
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ defaults:
+ run:
+ working-directory: "kafka-reactor/boot-kafka-reactor-consumer"
+ steps:
+ - uses: actions/checkout@v3
+ with:
+ fetch-depth: 0
+ - name: Set up JDK
+ uses: actions/[email protected]
+ with:
+ java-version: '17'
+ distribution: 'adopt'
+ cache: 'maven'
+ - name: Build with Maven
+ run: ./mvnw -B verify --file pom.xml

kafka-reactor/boot-kafka-reactor-producer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java

@@ -33,8 +33,7 @@ KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
  DockerImageName.parse("confluentinc/cp-kafka").withTag("7.4.1"))
  .withKraft();
- propertyRegistry.add("spring.kafka.producer.bootstrapServers", kafkaContainer::getBootstrapServers);
- propertyRegistry.add("spring.kafka.consumer.bootstrapServers", kafkaContainer::getBootstrapServers);
+ propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
  return kafkaContainer;
  }