如何配置Spring cloud stream (kafka)使用protobuf作为序列化

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>
<dependency>
    <groupId>com.google.protobuf</groupId>
    <artifactId>protobuf-java</artifactId>
</dependency>

syntax = "proto3";

message Message {
    string content = 1;
}

protoc --java_out=src/main/java src/main/proto/message.proto

@EnableBinding(MessageProcessor.class)
public class MessageConsumer {

    @StreamListener(MessageProcessor.INPUT)
    public void handleMessage(Message.MessageProto message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message.getContent());
    }
}

@EnableBinding(MessageProcessor.class)
public class MessageProducer {

    private final MessageProcessor messageProcessor;

    public MessageProducer(MessageProcessor messageProcessor) {
        this.messageProcessor = messageProcessor;
    }

    public void sendMessage(String content) {
        Message.MessageProto message = Message.MessageProto.newBuilder()
                .setContent(content)
                .build();
        messageProcessor.output().send(MessageBuilder.withPayload(message).build());
    }
}

interface MessageProcessor {

    String INPUT = "messageInput";
    String OUTPUT = "messageOutput";

    @Input(INPUT)
    SubscribableChannel input();

    @Output(OUTPUT)
    MessageChannel output();
}

spring:
  cloud:
    stream:
      bindings:
        messageInput:
          destination: topic-name
          content-type: application/protobuf
        messageOutput:
          destination: topic-name
          content-type: application/protobuf
      kafka:
        binder:
          brokers: kafka-broker1:9092,kafka-broker2:9092
      bindings:
        messageInput:
          consumer:
            configuration:
              key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
              value.deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
        messageOutput:
          producer:
            configuration:
              key.serializer: org.apache.kafka.common.serialization.StringSerializer
              value.serializer: org.apache.kafka.common.serialization.ByteArraySerializer