produce messages

ProducerController.java

@RestController
@RequiredArgsConstructor
@Slf4j
public class ProducerController {

    private final KafkaTemplate<String, String> kafkaTemplate;

    @Value("${topic}")
    private String topic;

    @GetMapping("/produce/{message}")
    public void produceMessage(@PathVariable("message") final String message) {
        kafkaTemplate.send(topic, message);
    }
}