[BAEL-4847] Kafka SSL with Spring Boot client
This commit is contained in:
@@ -0,0 +1,23 @@
|
||||
package com.baeldung.kafka.ssl;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.kafka.core.KafkaTemplate;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@AllArgsConstructor
|
||||
@Component
|
||||
public class KafkaProducer {
|
||||
|
||||
private final KafkaTemplate<String, String> kafkaTemplate;
|
||||
|
||||
public void sendMessage(String message, String topic) {
|
||||
log.info("Producing message: {}", message);
|
||||
kafkaTemplate.send(topic, "key", message)
|
||||
.addCallback(
|
||||
result -> log.info("Message sent to topic: {}", message),
|
||||
ex -> log.error("Failed to send message", ex)
|
||||
);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user