The franz-go feature gate has been in Beta since v0.137.0, I think it's had enough baking time to move it to Stable. I propose we do that, and give it 2 releases before removing the feature gate altogether.
|
// franzGoConsumerFeatureGateName is the name of the feature gate for franz-go consumer |
|
const franzGoConsumerFeatureGateName = "receiver.kafkareceiver.UseFranzGo" |
|
|
|
// franzGoConsumerFeatureGate is a feature gate that controls whether the Kafka receiver |
|
// uses the franz-go client or the Sarama client for consuming messages. When enabled, |
|
// the Kafka receiver will use the franz-go client, which is more performant and has |
|
// better support for modern Kafka features. |
|
var franzGoConsumerFeatureGate = featuregate.GlobalRegistry().MustRegister( |
|
franzGoConsumerFeatureGateName, featuregate.StageBeta, |
|
featuregate.WithRegisterDescription("When enabled, the Kafka receiver will use the franz-go client to consume messages."), |
|
featuregate.WithRegisterFromVersion("v0.129.0"), |
|
) |
