configure properties at correct place

rajadilipkolli · May 12, 2023 · 708668f · 708668f
1 parent 2b99035
commit 708668f
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 12 deletions.
diff --git a/kafka-avro/spring-boot-kafka-avro-consumer/src/main/resources/application.properties b/kafka-avro/spring-boot-kafka-avro-consumer/src/main/resources/application.properties
@@ -1,8 +1,3 @@
-spring.kafka.producer.bootstrap-servers=http://localhost:9092
-spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
-spring.kafka.producer.value-serializer=io.confluent.kafka.serializers.KafkaAvroSerializer
-spring.kafka.producer.properties.schema.registry.url=http://localhost:8081
-
 spring.kafka.consumer.bootstrap-servers=http://localhost:9092
 spring.kafka.consumer.group-id=group-1
 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer

diff --git a/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java b/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java
@@ -24,7 +24,11 @@
 
 import java.time.Duration;
 
-@SpringBootTest
+@SpringBootTest(
+ properties = {
+ "spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer",
+ "spring.kafka.producer.value-serializer=io.confluent.kafka.serializers.KafkaAvroSerializer"
+ })
 @AutoConfigureMockMvc
 @Import(KafkaProducer.class)
 class SpringBootKafkaAvroConsumerApplicationTests {

diff --git a/kafka-avro/spring-boot-kafka-avro-producer/src/main/resources/application.properties b/kafka-avro/spring-boot-kafka-avro-producer/src/main/resources/application.properties
@@ -3,11 +3,6 @@ spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.Strin
 spring.kafka.producer.value-serializer=io.confluent.kafka.serializers.KafkaAvroSerializer
 spring.kafka.producer.properties.schema.registry.url=http://localhost:8081
 
-spring.kafka.consumer.bootstrap-servers=http://localhost:9092
-spring.kafka.consumer.group-id=group-1
-spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
-spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer
-
 spring.kafka.properties.schema.registry.url=http://localhost:8081
 #Use Specific Record or else you get Avro GenericRecord.
 spring.kafka.properties.specific.avro.reader=true

diff --git a/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroProducerApplicationTests.java b/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroProducerApplicationTests.java
@@ -26,7 +26,12 @@
 
 import java.time.Duration;
 
-@SpringBootTest
+@SpringBootTest(
+ properties = {
+ "spring.kafka.consumer.group-id=group-1",
+ "spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer",
+ "spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer"
+ })
 @AutoConfigureMockMvc
 @Import(AvroKafkaListener.class)
 @ExtendWith(OutputCaptureExtension.class)