小编gug*_*uli的帖子

我想在 kafka 主题中生成一条消息。该消息应该具有以下模式：

   {"targetFileInfo":{"path":"2018-05-07-10/row01-small-01.txt.ready"}}

我知道这是一个 json 模式，那么我如何将该 json 转换为字符串？

我使用的是maven项目，所以需要使用哪些依赖

 String stringData = JSON.stringify({"targetFileInfo":{"path":"2018-05-07-10/row01-small-01.txt.ready"}});

所以我认为最好不要将 Json 转换为字符串并将该消息发送到 kafka 主题。

我的代码是这样的，它可以发送一个字符串，但我不知道如何修改我的代码来发送上面的消息。也许你可以帮助我。

 Producer<String, String> producer = null;

    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("acks", "all");
    props.put("retries", 0);
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    producer = new KafkaProducer<>(props);
    String msg = "welcome";
    producer.send(new ProducerRecord<String, String>("event", msg));

    producer.close();