Kafka Consumer topic을 pattern으로 정의하기
2025. 3. 27. 21:01ㆍk8s/Kafka
@KafkaListener(topicPattern = "TEST.*", groupId = "test")
public void consume(GenericRecord record, Acknowledgment ack) {
// your logic
}
2025. 3. 27. 21:01ㆍk8s/Kafka
@KafkaListener(topicPattern = "TEST.*", groupId = "test")
public void consume(GenericRecord record, Acknowledgment ack) {
// your logic
}