fluent / fluent/fluent-plugin-kafka

Support for Confluent Schema Registry?

Open
#288 3 comments 0 reactions 0 assignees View on GitHub
enhancement
Dominant language
Ruby
Stars
307
Forks
178
Avg merge
10h 37m
Merged PRs (30d)
13

Description

We are using https://github.com/takebayashi/fluent-plugin-avro to format our messages as Avro, but when sending to our kafka cluster, we need to prefix the avro data with 5 bytes to conform with the Confluent Schema Registry, as described here:

https://docs.confluent.io/current/schema-registry/serializer-formatter.html#wire-format

Is this possible? Is there a buffer or filter plugin that allows us to modify the raw bytes sent to Kafka after it has been formatted but before it is sent?

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.