Skip to content

Instantly share code, notes, and snippets.

@sohangp

sohangp/KafkaSink.java

Created October 2, 2019 01:28
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sohangp/53c8b23a641b1ebbcd619dceba46f3a8 to your computer and use it in GitHub Desktop.
Save sohangp/53c8b23a641b1ebbcd619dceba46f3a8 to your computer and use it in GitHub Desktop.
Download ZIP
Publish Kafka Message
Raw
KafkaSink.java
public void sink(Map<String, Object> polledMessage) {
log.info("Sending to message broker: {}", polledMessage);
String topic = ((String) polledMessage.get("event_type")).toLowerCase();
String payload = (String) polledMessage.get("payload");
kafkaTemplate.send(topic, payload);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment