Hagen H

`schema_registry_encode` truncation of input json before encode

3

I previously [posted an issue ](https://github.com/benthosdev/benthos/issues/2497)with `schema_registry_encode` that was resolved by fixing a race condition I'm getting similar issues with, but an extra key is now truncated: ```json {"key_1": 1,...

# What Adding addition kafka configuration parameters that can be passed from `kafka_franz` input to the underlying franz client opts. the configurations added are: ```go kgo.FetchMinBytes(int32(f.fetchMinBytes)), kgo.FetchMaxWait(f.fetchMaxWaitDuration), kgo.FetchMaxPartitionBytes(int32(f.maxPartitionFetchBytes)), ``` #...

Adds functionality to `schema_registry_decode` to emit defaults or not

1

# What This PR allows users to specify different behaviour for `schema_registry_decode` when decoding `protobuf` messages; allowing them to chose to Emit defaults. # Why if a protobuf message like...

[INFOPLAT-1560](https://smartcontract-it.atlassian.net/browse/INFOPLAT-1560) ## What Allows usage of dynamic auth headers by implementing `grpc.PerRPCCredentials` & setting as a `DialOption` on the otel client ## Why Makes tokens expire, in the case that...

INFOPLAT-2963 beholder rotating auth headers core wire up

2

## [INFOPLAT-2963](https://smartcontract-it.atlassian.net/browse/INFOPLAT-2963) - Sets signing mechanism for `beholder` auth headers - Adds `AuthHeadersTTL` configuration ~ Allows `static` vs `rotating` auth headers to be enabled via `toml` [INFOPLAT-2963]: https://smartcontract-it.atlassian.net/browse/INFOPLAT-2963?atlOrigin=eyJpIjoiNWRkNTljNzYxNjVmNDY3MDlhMDU5Y2ZhYzA5YTRkZjUiLCJwIjoiZ2l0aHViLWNvbS1KU1cifQ