[Spring] SpringBoot + Kafka 사용 방법

의존성 설정

<dependency>
    <groupId>org.springframework.kafka</goupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

 

application.properties

kafka.bootstrap=localhost:9092
ping.topic.name=msa

 

Publisher

KafkaSampleProducerService

 

@Service
public class KafkaSampleProducerService {
	@Autowired
	private KafkaTemplate<String, String> kafkaTemplate;
	public void sendMessage(String message) {
		System.out.println("send message : " + message);
		this.kafkaTemplate.send("oingdaddy", message);
	}
}

- KafkaTemplate가 핵심 요소

- Kafka 서버로 바로 통신할 수 있도록 해줌

- send(topic, message);

 

 

 

Subscriber

@Service
public class KafkaSampleConsumerService {
    @KafkaListener(topics = "oingdaddy", groupId = "group-id-oing")
    public void consume(String message) throws IOException {
        System.out.println("receive message : " + message);
    }
}

 

- Zookeeper/Kafka 서버 실행 후, publisher 실행

- subscriber에서 ping 보낸 것을 받을 수 있음