Merge pull request #373 from Kernel360/fix/#372-event-hub-설정-되돌리기

fix: 설정 되돌리기

Author: tomatozil

monicar-event-hub/src/main/java/org/eventhub/config/KafkaProducerConfig.java

@@ -1,10 +1,10 @@
 package org.eventhub.config;
 
 import java.util.HashMap;
+
 import java.util.Map;
 
 import org.apache.kafka.clients.producer.ProducerConfig;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Bean;
@@ -15,7 +15,6 @@
 import org.springframework.kafka.core.ProducerFactory;
 import org.springframework.kafka.support.serializer.JsonSerializer;
 
-
 @Configuration
 public class KafkaProducerConfig {
 
@@ -46,9 +45,4 @@ public ProducerFactory<String, Object> producerFactory(KafkaProperties kafkaProp
 	public KafkaTemplate<String, Object> kafkaTemplate(KafkaProperties kafkaProperties) {
 		return new KafkaTemplate<>(producerFactory(kafkaProperties));
 	}
-
-	@Bean
-	public PartitionFinder finder(@Qualifier("producerFactory") ProducerFactory<String, Object> producerFactory) {
-		return new PartitionFinder(producerFactory);
-	}
-}
+}

monicar-event-hub/src/main/java/org/eventhub/config/PartitionFinder.java

@@ -21,8 +21,6 @@ public class KafkaCycleInfoEventPublisher implements CycleInfoEventPublisher {
 
 	@Override
 	@Async
-	@KafkaListener(topicPartitions = @TopicPartition(topic = "cycleInfo-json-topic",
-		partitions = "#{@finder.partitions('cycleInfo-json-topic')}"))
 	public void publishEvent(CycleInfoList cycleInfoList) {
 		CycleInfoListCommand message = CycleInfoListCommand.from(cycleInfoList);