使用Kafka绑定器在Spring cloud中打印JsonObject

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>

spring.cloud.stream.bindings.output.destination=your-topic-name
spring.cloud.stream.bindings.output.content-type=application/json

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.MessageBuilder;

@EnableBinding(KafkaSender.KafkaOutputChannel.class)
public class KafkaSender {

    private final KafkaOutputChannel outputChannel;

    public KafkaSender(KafkaOutputChannel outputChannel) {
        this.outputChannel = outputChannel;
    }

    public void sendJsonObject(JsonObject jsonObject) {
        outputChannel.output().send(MessageBuilder.withPayload(jsonObject.toString()).build());
    }

    public interface KafkaOutputChannel {
        String OUTPUT = "output";

        @Output(OUTPUT)
        MessageChannel output();
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class KafkaController {

    private final KafkaSender kafkaSender;

    @Autowired
    public KafkaController(KafkaSender kafkaSender) {
        this.kafkaSender = kafkaSender;
    }

    @PostMapping("/send")
    public void sendMessage(@RequestBody JsonObject jsonObject) {
        kafkaSender.sendJsonObject(jsonObject);
    }
}