avro - 尝试在 Spring Cloud Stream 中解码 Avro 消息时出现无法识别的 header 字节错误

Question

我正在尝试为我的 Spring Cloud Stream 应用程序编写一个测试用例。我将 Confluence Schema Registry 与 Avro 结合使用，因此我需要在从 channel 轮询后对消息进行解码。这是我的代码:

    processor.input()
        .send(MessageBuilder.withPayload(InputData).build());

    Message<?> message = messageCollector.forChannel(processor.output()).poll();

    BinaryMessageDecoder<OutputData> decoder = OutputData.getDecoder();
    OutputData outputObject = decoder.decode((byte[]) message.getPayload());

由于某种原因，此代码抛出

org.apache.avro.message.BadHeaderException: Unrecognized header bytes: 0x00 0x08

我不确定这是否是我面临的某种错误，或者我没有遵循正确的方法来解码收到的 avro 消息。我怀疑我需要用某些东西设置标题，但我不太确定如何以及具体用什么设置。如果有人能帮助我解决这个问题，我将不胜感激。

P.S:我使用 spring-cloud-stream-test-support 来进行此测试。

Answer 1

使用测试绑定(bind)器时，数据不会进行 avro 编码。

测试 Binder 非常有限。

要使用 avro 正确进行端到端测试，您应该删除测试绑定(bind)器并使用带有嵌入式 kafka 代理的真实 kafka 绑定(bind)器。

sample apps 之一展示了如何做到这一点。