warmup

Documentation

Index

• func WarmUpSRCache(logger log.Logger, mutex *sync.Mutex, batch parsers.MessageBatch, ...)

Functions

func WarmUpSRCache

func WarmUpSRCache(logger log.Logger, mutex *sync.Mutex, batch parsers.MessageBatch, schemaRegistryClient *confluent.SchemaRegistryClient, notFoundIsOk bool)

It's important to warn-up Schema-Registry cache single-thread, to not to DDoS Schema-Registry mutex we need not bcs of something is thread-unsafe, but to reduce schema-registry RPS