benthosdev/benthos v3.8.0

on GitHub

Added

• New field max_in_flight added to the following outputs:
  • amqp_0_9
  • cache
  • dynamodb
  • elasticsearch
  • gcp_pubsub
  • hdfs
  • http_client
  • kafka
  • kinesis
  • kinesis_firehose
  • mqtt
  • nanomsg
  • nats
  • nats_stream
  • nsq
  • redis_hash
  • redis_list
  • redis_pubsub
  • redis_streams
  • s3
  • sns
  • sqs
• Batching fields added to the following outputs:
  • dynamodb
  • elasticsearch
  • http_client
  • kafka
  • kinesis
  • kinesis_firehose
  • sqs
• More TRACE level logs added throughout the pipeline.
• Operator delete added to cache processor.
• Operator explode added to json processor.
• Field storage_class added to s3 output.
• Format json_map added to unarchive processor.

Fixed

• Function interpolated strings within the json processor value field are
  now correctly unicode escaped.
• Retry intervals for kafka output have been tuned to prevent circuit breaker
  throttling.