💫 New Features & Changes
- Changed partition strategy for rebalancing from default (
RangeAssignor
) toStickyAssignor
. (#2299, @aavarghese) - Failed events are now decorated with Knative error extensions when routed to the
deadLetterSink
for more context (#2374, @egorlepa) - Kafka Broker and KafkaSink ignore a trailing slash in the HTTP path. (#2462, @pierDipi)
- Specify a different
contentMode
on KafkaSink objects wasn't having any effect, now structured or binary content mode are properly handled. (#2466, @pierDipi) - The default max.partition.fetch.bytes is
65536
andmax.poll.records
is 50. (#2456, @pierDipi)
🐞 Bug Fixes
- When using ordered delivery with slow consumers, unnecessary consumer group rebalances might be triggered, which causes higher e2e latency and increased duplicates. (#2432, @pierDipi)
Dependencies
Added
- github.com/agnivade/levenshtein: v1.0.1
- github.com/andreyvit/diff: c7f18ee
- github.com/docker/go-units: v0.4.0
- github.com/globalsign/mgo: eeefdec
- github.com/go-openapi/analysis: v0.19.5
- github.com/go-openapi/errors: v0.19.2
- github.com/go-openapi/loads: v0.19.4
- github.com/go-openapi/runtime: v0.19.4
- github.com/go-openapi/strfmt: v0.19.3
- github.com/go-openapi/validate: v0.19.5
- github.com/gophercloud/gophercloud: c818fa6
- github.com/manifestival/client-go-client: v0.5.0
- github.com/manifestival/manifestival: v0.7.1
- github.com/mattn/go-runewidth: v0.0.2
- github.com/olekukonko/tablewriter: a0225b3
- github.com/pborman/uuid: v1.2.0
- github.com/sergi/go-diff: v1.0.0
- github.com/tidwall/pretty: v1.0.0
- github.com/ugorji/go: v1.1.4
- github.com/urfave/cli: v1.20.0
- github.com/vektah/gqlparser: v1.1.2
- go.etcd.io/etcd: 17cef6e
- go.mongodb.org/mongo-driver: v1.1.2
- go.uber.org/tools: 2cfd321
- gopkg.in/cheggaaa/pb.v1: v1.0.25
- gotest.tools: v2.2.0+incompatible
- sigs.k8s.io/controller-runtime: v0.7.2
- sigs.k8s.io/structured-merge-diff/v3: 67a7b8c
Changed
- github.com/go-openapi/spec: 6aced65 → v0.19.3
- github.com/imdario/mergo: v0.3.9 → v0.3.10
- github.com/kr/pty: v1.1.1 → v1.1.5
- github.com/mattn/go-isatty: v0.0.3 → v0.0.4
- k8s.io/api: v0.23.8 → v0.23.9
- k8s.io/apiextensions-apiserver: v0.23.8 → v0.23.9
- k8s.io/apimachinery: v0.23.8 → v0.23.9
- k8s.io/apiserver: v0.23.8 → v0.23.9
- k8s.io/client-go: v0.23.8 → v0.23.9
- k8s.io/code-generator: v0.23.8 → v0.23.9
- k8s.io/component-base: v0.23.8 → v0.23.9
- k8s.io/gengo: 4627b89 → 397b4ae
- k8s.io/klog/v2: 43cc75f → 0990e81
- knative.dev/control-protocol: 827b25d → f18dbde
- knative.dev/eventing-kafka: v0.33.0 → v0.34.0
- knative.dev/eventing: v0.33.0 → v0.34.1
- knative.dev/hack/schema: 65c463a → 8d1e4cc
- knative.dev/hack: 65c463a → 8d1e4cc
- knative.dev/pkg: e60d250 → 4a03844
- knative.dev/reconciler-test: f05db88 → 177f826
Removed
Nothing has changed.