Send message to Kafka

Send_message_examole.md

In your class autowire (@@Autowired for Spring or @Inject for Guice)

@Autowired
private  IMessagingFactory messagingFactory;

import io.gitbub.devlibx.easy.helper.json.JsonUtils;

Object logEvent = ...
messagingFactory.getProducer("updateUserEvent")
        .ifPresent(producer -> producer.send(key, JsonUtils.asJson(logEvent)));