Sha256: 1dc89dfac803a17565ab94af2fa79a0926c1a21bdaed796e3ef416650a35ca31
Contents?: true
Size: 693 Bytes
Versions: 8
Compression:
Stored size: 693 Bytes
Contents
package org.embulk.output.kafka; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; import org.apache.kafka.common.serialization.Serializer; public class KafkaJsonSerializer implements Serializer<ObjectNode> { private static ObjectMapper objectMapper = new ObjectMapper(); @Override public byte[] serialize(String topic, ObjectNode data) { try { return objectMapper.writeValueAsBytes(data); } catch (JsonProcessingException e) { e.printStackTrace(); throw new RuntimeException(e); } } }
Version data entries
8 entries across 8 versions & 1 rubygems