more improvements

Author: rajadilipkolli

kafka-avro/spring-boot-kafka-avro-consumer/src/main/resources/application.properties

@@ -8,5 +8,6 @@ spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvr
 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
+spring.threads.virtual.enabled=true
 
 spring.jpa.open-in-view=false

kafka-spring-boot/boot-concurrent-kafka-consumer/src/main/resources/application.properties

@@ -4,4 +4,5 @@ spring.kafka.bootstrap-servers=localhost:9092
 spring.kafka.client-id=concurrent-kafka
 spring.kafka.consumer.group-id=concurrent-kafka-consumer
 spring.kafka.listener.change-consumer-thread-name=true
-spring.kafka.listener.concurrency=3
+spring.kafka.listener.concurrency=3
+spring.threads.virtual.enabled=true

kafka-spring-boot/boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/common/ContainerConfiguration.java

@@ -24,7 +24,7 @@ KafkaContainer kafkaContainer() {
     }
 
     @Bean
-    public DynamicPropertyRegistrar kafkaProperties(KafkaContainer kafkaContainer) {
+    DynamicPropertyRegistrar kafkaProperties(KafkaContainer kafkaContainer) {
         return (properties) -> {
             // Connect our Spring application to our Testcontainers Kafka instance
             properties.add("spring.kafka.consumer.bootstrap-servers", kafkaContainer::getBootstrapServers);

kafka-spring-cloud-sample/src/main/java/com/example/cloudkafkasample/sink/Receiver.java

@@ -24,7 +24,7 @@ public CountDownLatch getLatch() {
     }
 
     @Bean
-    public Consumer<List<MessageDTO>> receive() {
+    Consumer<List<MessageDTO>> receive() {
         return batchMessages -> {
             AtomicInteger i = new AtomicInteger();
             logger.info("Number of messages in batch : {}", batchMessages.size());

kafka-spring-cloud-sample/src/test/java/com/example/cloudkafkasample/common/ContainersConfig.java

@@ -18,7 +18,7 @@ KafkaContainer kafkaContainer() {
     }
 
     @Bean
-    public DynamicPropertyRegistrar kafkaProperties(KafkaContainer kafkaContainer) {
+    DynamicPropertyRegistrar kafkaProperties(KafkaContainer kafkaContainer) {
         return (properties) -> {
             // Connect our Spring application to our Testcontainers Kafka instance
             properties.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers);