fluentd 是否支持 HTTP 输入中的 protobuf 消息？

Question

是否可以将 protobuf 消息发送到 Fluentd？

我不是在请求 protobuf 解析，只是接收 protobuf 并将其发送到输出。

配置示例：

<source>
# Here I would receive the protobuf message
@type http
port 9880
bind 0.0.0.0
body_size_limit 32m
keepalive_timeout 10s
</source>

<match hello>
# And here I'd send the protobuf message to another endpoint
@type http

endpoint "http://localhost:9999"
open_timeout 2

<buffer>
flush_interval 1s
</buffer>
</match>

有了这个配置，流利的回答：

400 Bad Request
'json' or 'msgpack' parameter is required

Answer 1

您可以将 fluent-plugin-protobuf-http 用于 single/batch 输入协议缓冲区的根据自定义模式编码的消息（.proto 文件）。