revert bean creation

Author: rajadilipkolli

order-service/src/main/java/com/example/orderservice/config/kafka/KafkaStreamsConfig.java

@@ -14,12 +14,8 @@ Licensed under MIT License Copyright (c) 2023 Raja Kolli.
 import com.example.common.dtos.OrderDto;
 import com.example.orderservice.services.OrderManageService;
 import java.time.Duration;
-import java.util.HashMap;
-import java.util.Map;
 import java.util.Properties;
-import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.serialization.ByteArraySerializer;
 import org.apache.kafka.common.serialization.Serde;
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.streams.StreamsBuilder;
@@ -35,13 +31,10 @@ Licensed under MIT License Copyright (c) 2023 Raja Kolli.
 import org.apache.kafka.streams.state.Stores;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.boot.autoconfigure.kafka.KafkaConnectionDetails;
-import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.annotation.EnableKafkaStreams;
 import org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer;
-import org.springframework.kafka.core.DefaultKafkaProducerFactory;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.core.ProducerFactory;
 import org.springframework.kafka.listener.DeadLetterPublishingRecoverer;
@@ -79,18 +72,6 @@ StreamsBuilderFactoryBeanConfigurer configurer(
         };
     }
 
-    @Bean
-    ProducerFactory<byte[], byte[]> bytesProducerFactory(
-            KafkaProperties kafkaProperties, KafkaConnectionDetails connectionDetails) {
-        Map<String, Object> props = new HashMap<>(kafkaProperties.buildProducerProperties());
-        props.put(
-                ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
-                connectionDetails.getStreamsBootstrapServers());
-        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
-        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
-        return new DefaultKafkaProducerFactory<>(props);
-    }
-
     @Bean
     DeadLetterPublishingRecoverer deadLetterPublishingRecoverer(
             ProducerFactory<byte[], byte[]> producerFactory) {