mindol1004/reactor-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

카프카 로컬로 변경

Browse Source 
카프카 로컬서버로 변경
This commit is contained in:
deogicorgi
2022-04-14 21:07:17 +09:00
parent bce4eb7ada
commit d3cedbb8ed
3 changed files with 20 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
consumer/src/main/java/com/github/deogicorgi/reactive/consumer/config/KafkaConfig.java
View File

@@ -23,16 +23,16 @@ public class KafkaConfig {
private final KafkaProperties properties; private final KafkaProperties properties;
// deogicorgi-uri 리시버 // deogicorgi-topic-1 리시버
@Bean("uriMessageReceiver") @Bean("deogicorgiTopic1")
public KafkaReceiver<Integer, String> uriMessageReceiver() throws Exception { public KafkaReceiver<Integer, String> uriMessageReceiver() throws Exception {
Map.Entry<String, KafkaReceiverProperty> deogicorgiUri = properties.getProperty("deogicorgiUri").orElse(null); Map.Entry<String, KafkaReceiverProperty> propertyEntry = properties.getProperty("deogicorgi-topic-1").orElse(null);
if (ObjectUtils.isEmpty(deogicorgiUri)) { if (ObjectUtils.isEmpty(propertyEntry)) {
throw new Exception("property is null"); throw new Exception("property is null");
} }
KafkaReceiverProperty property = deogicorgiUri.getValue(); KafkaReceiverProperty property = propertyEntry.getValue();
ReceiverOptions<Integer, String> receiverOptions = ReceiverOptions<Integer, String> receiverOptions =
ReceiverOptions.<Integer, String>create(getConsumerProps(property)) ReceiverOptions.<Integer, String>create(getConsumerProps(property))
@@ -41,16 +41,16 @@ public class KafkaConfig {
return KafkaReceiver.create(receiverOptions); return KafkaReceiver.create(receiverOptions);
} }
// deogicorgi-message 리시버 // deogicorgi-topic-2 리시버
@Bean("messageReceiver") @Bean("deogicorgiTopic2")
public KafkaReceiver<Integer, String> messageReceiver() throws Exception { public KafkaReceiver<Integer, String> messageReceiver() throws Exception {
Map.Entry<String, KafkaReceiverProperty> deogicorgiUri = properties.getProperty("deogicorgiMessage").orElse(null); Map.Entry<String, KafkaReceiverProperty> propertyEntry = properties.getProperty("deogicorgi-topic-2").orElse(null);
if (ObjectUtils.isEmpty(deogicorgiUri)) { if (ObjectUtils.isEmpty(propertyEntry)) {
throw new Exception("property is null"); throw new Exception("property is null");
} }
KafkaReceiverProperty property = deogicorgiUri.getValue(); KafkaReceiverProperty property = propertyEntry.getValue();
ReceiverOptions<Integer, String> receiverOptions = ReceiverOptions<Integer, String> receiverOptions =
ReceiverOptions.<Integer, String>create(getConsumerProps(property)) ReceiverOptions.<Integer, String>create(getConsumerProps(property))

18
consumer/src/main/resources/application.yml
View File

@@ -1,11 +1,11 @@
kafka: kafka:
hosts: deogicorgi.home:29092 hosts: localhost:9092
receiver : receiver :
uri: deogicorgi-topic-1:
name : deogicorgiUri name : deogicorgi-topic-1
topic : deogicorgi-uri topic : deogicorgi-topic-1
groupId : deogicorgi-uri-1 groupId : deogicorgi-topic-1
message: deogicorgi-topic-2:
name : deogicorgiMessage name : deogicorgi-topic-2
topic : deogicorgi-message topic : deogicorgi-topic-2
groupId : deogicorgi-message-1 groupId : deogicorgi-topic-2

2
producer/src/main/resources/application.yml
View File

@@ -2,5 +2,5 @@ server:
port: 18080 port: 18080
kafka: kafka:
hosts: deogicorgi.home:29092 hosts: localhost:9092