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