Skip to content

Commit e6e412d

Browse files
committed
chore: 쿠버네티스용으로 카프카 url 변경
1 parent cdb968d commit e6e412d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/gucci/blog_service/kafka/producer/KafkaProducerConfig.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,8 @@
2020
public class KafkaProducerConfig {
2121
private Map<String, Object> producerConfigs() {
2222
Map<String, Object> props = new HashMap<>();
23-
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); // 필요시 수정
23+
// props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); // 필요시 수정
24+
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka.kafka.svc.cluster.local:9092"); // 필요시 수정
2425
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
2526
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, org.springframework.kafka.support.serializer.JsonSerializer.class);
2627
props.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false);

0 commit comments

Comments
 (0)