Blue-Green for Kafka clients

• Blue-Green for Kafka clients
  • Blue Green Version tracking filter

This library provides abstract implementation to consume messages from Kafka in Cloud-Core Blue Green scenarios

The library is extended by adapters, refer to the documentation of particular adapter:

• segmentio adapter

Blue Green Version tracking filter

This library provides implementation of Blue Green version filter by filter.go.
This implementation depends on blue-green-state-monitor-go library.

Usage example:

import (
    "context"
    "fmt"
    bgState "github.com/netcracker/qubership-core-lib-go-bg-state-monitor/v2"
    bgKafka "github.com/netcracker/qubership-core-lib-go-maas-bg-kafka/v3"
)

func FilterDemo(statePublisher *bgState.ConsulBlueGreenStatePublisher) {
    filter := bgKafka.NewTrackingVersionFilter(context.Background(), statePublisher)
    result = filter.Test("v1")
}