Skip to content

Release protocol/kafka_sarama/v2.3.0
Compare
Choose a tag to compare
@github-actions github-actions released this 28 Sep 16:37
protocol/kafka_sarama/v2.3.0
68306c1
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

General

  • Better data handling when calling binding.ToEvent @ian-mi
  • Corrected client.Invoke error messaging format @odacremolbap
  • Client no longer blocked on GOMAXPROC receivers @n3wscott
  • Recover from panic in client.Invoke from handler function @matejvasek
  • Client receiver/responder functions: Fix handler input types variance. @matejvasek
  • StartReceiver returns if it can't start listening @matejvasek

HTTP

  • now will retry for returned 502 status code from target @duglin
  • new http.NewObserved adds trace propagating middleware to the created HTTP protocol and is used to add trace
    propagation to the default HTTP client. @ian-mi

GoChan

  • Constructor of sender fixed, transformers now passed @odacremolbap

Kafka

  • allow to construct mock sender for unit testing @aslom

Pub/Sub

  • Copy of buffer prevented when writing to pubsub.Message @ian-mi
Assets 2
Loading