SHARE
TWEET

Untitled

a guest Jan 20th, 2020 65 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.         KStreamBuilder builder = new KStreamBuilder();
  2.         Map<String, Object> serdeProps = new HashMap<>();
  3.         Serializer<Message> messageSerializer = new JsonPOJOSerializer<>();
  4.         serdeProps.put("JsonPOJOClass", Message.class);
  5.         messageSerializer.configure(serdeProps, false);
  6.  
  7.         Deserializer<Message> messageDeserializer = new JsonPOJODeserializer<>();
  8.         serdeProps.put("JsonPOJOClass", Message.class);
  9.         messageDeserializer.configure(serdeProps, false);
  10.  
  11.         Serde<Message> messageSerde = Serdes.serdeFrom(messageSerializer, messageDeserializer);
  12.         builder.stream(Serdes.Long(), messageSerde, "cancelSP")
  13.                 .mapValues(value -> {
  14.                     return new Message(...);
  15.                 }).to("cancelSP");
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
Top