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

Version Path
embulk-output-kafka-0.1.7 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.6 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.5 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.4 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.3 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.2 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.1 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java
embulk-output-kafka-0.1.0 src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java