Knative Eventing Kafka Broker release v0.22.1

Release notes for Knative Eventing Kafka Broker

• Eventing Kafka Broker Documentation
• Eventing Kafka Sink Documentation

Changelog since 0.21

Changes by Kind

Enhancement

• Support ordered delivery.
  You can choose between ordered and unordered delivery through the label kafka.eventing.knative.dev/delivery.order in your triggers.
  Check out the docs for more details at https://knative.dev/docs/eventing/broker/kafka-broker/ (#589, @slinkydeveloper)

Bug or Regression

• Add producer interceptor io.cloudevents.kafka.PartitionKeyExtensionInterceptor to provide ordered delivery based on the partitioning extension of the CloudEvents spec. (#751, @pierDipi)
• Fix unable to deploy KafkaSink without Kafka Broker installed (#714, @pierDipi)

Breaking changes

• Kubernetes's minimum version is 1.18. (#779, @pierDipi)

Knative Eventing Kafka Broker release v0.22.0

Release notes for Knative Eventing Kafka Broker

• Eventing Kafka Broker Documentation
• Eventing Kafka Sink Documentation

Changelog since 0.21

Changes by Kind

Enhancement

• Support ordered delivery.
  You can choose between ordered and unordered delivery through the label kafka.eventing.knative.dev/delivery.order in your triggers.
  Check out the docs for more details at https://knative.dev/docs/eventing/broker/kafka-broker/ (#589, @slinkydeveloper)

Bug or Regression

• Add producer interceptor io.cloudevents.kafka.PartitionKeyExtensionInterceptor to provide ordered delivery based on the partitioning extension of the CloudEvents spec. (#751, @pierDipi)
• Fix unable to deploy KafkaSink without Kafka Broker installed (#714, @pierDipi)

Breaking changes

• Kubernetes's minimum version is 1.18. (#779, @pierDipi)

Knative Eventing Kafka Broker release v0.21.2

Release notes for Eventing Kafka Broker

• Eventing Kafka Broker Documentation
• Eventing Kafka Sink Documentation

Changelog since 0.21.1

Bug Fixes

• Add producer interceptor PartitionKeyExtensionInterceptor (#754)

Knative Eventing Kafka Broker release v0.21.1

Release notes for Eventing Kafka Broker

• Eventing Kafka Broker Documentation
• Eventing Kafka Sink Documentation

Changelog since 0.20.0

Enhancements

• Add support for SASL and SSL. (#534, @pierDipi)
  • Eventing Kafka Broker documentation
  • Eventing Kafka Sink documentation
• Add support for Trigger.Spec.DeliverySpec (#612, @pierDipi)
• Improve status fields description in KafkaSink CRD. (#552, @pierDipi)
• Reduce error logging noise on clean shutdown. (#625, @pierDipi)
• Support Kubernetes 1.20. (#542, @pierDipi)

Bug Fixes

• Consume topic from the earliest offset (#557, @pierDipi)
• Fix offset management (#597, @slinkydeveloper)
• Data plane reconciler handles failed reconciliation. (#568, @pierDipi)
• Fix TimeoutException and DnsNameResolverTimeoutException. (#539, @pierDipi)

Knative Eventing Kafka Broker release v0.21.0

Release notes for Eventing Kafka Broker

• Eventing Kafka Broker Documentation
• Eventing Kafka Sink Documentation

Changelog since 0.20.0

Enhancements

• Add support for SASL and SSL. (#534, @pierDipi)
  • Eventing Kafka Broker documentation
  • Eventing Kafka Sink documentation
• Add support for Trigger.Spec.DeliverySpec (#612, @pierDipi)
• Improve status fields description in KafkaSink CRD. (#552, @pierDipi)
• Reduce error logging noise on clean shutdown. (#625, @pierDipi)
• Support Kubernetes 1.20. (#542, @pierDipi)

Bug Fixes

• Consume topic from the earliest offset (#557, @pierDipi)
• Fix offset management (#597, @slinkydeveloper)
• Data plane reconciler handles failed reconciliation. (#568, @pierDipi)
• Fix TimeoutException and DnsNameResolverTimeoutException. (#539, @pierDipi)

Knative Eventing Kafka Broker release v0.20.1

Release notes for Eventing Kafka Broker 0.20.0

• Kafka Broker Documentation
• KafkaSink Documentation

🎁 New Features

• kafka-broker-receiver, kafka-broker-dispatcher, and kafka-sink-receiver expose Kafka client metrics. (#435, @pierDipi)
• kafka-broker-receiver, kafka-broker-dispatcher, and kafka-sink-receiver expose JVM metrics (disabled by default) (#435, @pierDipi)
• Data plane pods produce distributed tracing spans. (#421, @pierDipi)
• Receivers now specify anti-affinity so that replicas will not be colocated (#483, @arghya88)

🐛 Bug Fixes

• Controllers resync state when managed resources change. (#420, @pierDipi)
• Leader election transition improvements (#449, @arghya88)

🧹 Cleanup

• The data plane is completely non-blocking. (#438, @pierDipi)
• Skip ConfigMap update when there are no changes (#511, @pierDipi)
• Change release labels from eventing.knative.dev to kafka.eventing.knative.dev. (#480, @pierDipi)

Knative Eventing Kafka Broker release v0.20.0

Release notes for Eventing Kafka Broker 0.20.0

• Kafka Broker Documentation
• KafkaSink Documentation

🎁 New Features

• kafka-broker-receiver, kafka-broker-dispatcher, and kafka-sink-receiver expose Kafka client metrics. (#435, @pierDipi)
• kafka-broker-receiver, kafka-broker-dispatcher, and kafka-sink-receiver expose JVM metrics (disabled by default) (#435, @pierDipi)
• Data plane pods produce distributed tracing spans. (#421, @pierDipi)
• Receivers now specify anti-affinity so that replicas will not be colocated (#483, @arghya88)

🐛 Bug Fixes

• Controllers resync state when managed resources change. (#420, @pierDipi)
• Leader election transition improvements (#449, @arghya88)

🧹 Cleanup

• The data plane is completely non-blocking. (#438, @pierDipi)
• Skip ConfigMap update when there are no changes (#511, @pierDipi)
• Change release labels from eventing.knative.dev to kafka.eventing.knative.dev. (#480, @pierDipi)

Knative Eventing Kafka Broker release v0.19.0

Breaking Changes

• Default replication factor is 3 (1 previously) (#375, @sheetalsingala)

Actions Required (pre-upgrade)

• Run kubectl delete configmap -n knative-eventing kafka-broker-brokers-triggers

🎁 New Features

• eventing-kafka.yaml can be used to install Broker and KafkaSink. (#367, @pierDipi)
• Data plane pods expose server and client metrics in Prometheus format. (#231 #244, @pierDipi)
  • The receiver component exposes:
    • http_requests_produce_total - Number of accepted produce requests (200-level responses)
    • http_requests_malformed_total - Number of malformed produce requests (400-level responses)
  • The dispatcher component exposes:
    • http_events_sent_total - Number of events delivered to Apache Kafka
• The Broker retries sending events. (#268 #263 #258, @pierDipi)

🎁 Improvements

• The container image's sizes are ~90MB instead of ~287MB. (#265 #306, @pierDipi @slinkydeveloper)
• Gracefully clean up resources on shutdown (#334, @pierDipi)

🐛 Bug Fixes

• Remove config-logging volume from the controller (#288, @pierDipi)
• Thread blocked when logging large configurations in debug mode (#346 #378, @slinkydeveloper)

📖 Documentation

• KafkaSink usage: https://gist.github.com/matzew/e2c2fcd2696a346f25b8bc9e64bfd0fa (@matzew)

Knative Eventing Kafka Broker release v0.18.3

New features

• You can stream HTTP CloudEvents into Apache Kafka using KafkaSink objects: (#177, #134, @pierDipi)
• Now you can configure the server options:, modifying the config map config-kafka-broker-data-plane (#151, @slinkydeveloper)
• Now you can configure the web client options, modifying the config map config-kafka-broker-data-plane (#149, @slinkydeveloper)

Actions required (pre-upgrade):

• Allow independent installation of components (#176, @pierDipi)
  • Remove kafka-broker-controller
    • kubectl delete -n knative-eventing deployment kafka-broker-controller
    • kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-controller
    • kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-addressable-resolver
    • kubectl delete -n knative-eventing clusterroles.rbac.authorization.k8s.io kafka-broker-controller
    • kubectl delete -n knative-eventing serviceaccounts kafka-broker-controller

Actions required (post-upgrade):

• Allow independent installation of components (#176, @pierDipi)
  • Remove kafka-broker-config-logging (post-upgrade)
    • kubectl delete -n knative-eventing cm kafka-broker-config-logging

Fix bug

• Update Broker and Trigger status when there is a failure. (#157, @pierDipi)

---

Row markdown ⬇️

## New features

- You can stream HTTP CloudEvents into Apache Kafka using `KafkaSink` objects: ([#177](https://github.com/knative-sandbox/eventing-kafka-broker/pull/177), [#134](https://github.com/knative-sandbox/eventing-kafka-broker/pull/134), [@pierDipi](https://github.com/pierDipi))
- Now you can configure the [server options:](https://vertx-web-site.github.io/docs/apidocs/io/vertx/core/http/HttpServerOptions.html), modifying the config map `config-kafka-broker-data-plane` ([#151](https://github.com/knative-sandbox/eventing-kafka-broker/pull/151), [@slinkydeveloper](https://github.com/slinkydeveloper))
- Now you can configure the [web client options](https://vertx-web-site.github.io/docs/apidocs/io/vertx/ext/web/client/WebClientOptions.html), modifying the config map `config-kafka-broker-data-plane` ([#149](https://github.com/knative-sandbox/eventing-kafka-broker/pull/149), [@slinkydeveloper](https://github.com/slinkydeveloper))

## Actions required (pre-upgrade): 

  - Allow independent installation of components ([#176](https://github.com/knative-sandbox/eventing-kafka-broker/pull/176), [@pierDipi](https://github.com/pierDipi))
    - Remove `kafka-broker-controller`
      - `kubectl delete -n knative-eventing deployment kafka-broker-controller`
      - `kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-controller`
      - `kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-addressable-resolver`
      - `kubectl delete -n knative-eventing clusterroles.rbac.authorization.k8s.io kafka-broker-controller`
      - `kubectl delete -n knative-eventing serviceaccounts kafka-broker-controller`
    
## Actions required (post-upgrade): 
  - Allow independent installation of components ([#176](https://github.com/knative-sandbox/eventing-kafka-broker/pull/176), [@pierDipi](https://github.com/pierDipi)) 
     - Remove `kafka-broker-config-logging` (post-upgrade) 
       - `kubectl delete -n knative-eventing cm kafka-broker-config-logging` 

## Fix bug 
  - Update Broker and Trigger status when there is a failure. ([#157](https://github.com/knative-sandbox/eventing-kafka-broker/pull/157), [@pierDipi](https://github.com/pierDipi))

Knative Eventing Kafka Broker release v0.18.2

New features

• You can stream HTTP CloudEvents into Apache Kafka using KafkaSink objects: (#177, #134, @pierDipi)
• Now you can configure the server options:, modifying the config map config-kafka-broker-data-plane (#151, @slinkydeveloper)
• Now you can configure the web client options, modifying the config map config-kafka-broker-data-plane (#149, @slinkydeveloper)

Actions required (pre-upgrade):

• Allow independent installation of components (#176, @pierDipi)
  • Remove kafka-broker-controller
    • kubectl delete -n knative-eventing deployment kafka-broker-controller
    • kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-controller
    • kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-addressable-resolver
    • kubectl delete -n knative-eventing clusterroles.rbac.authorization.k8s.io kafka-broker-controller
    • kubectl delete -n knative-eventing serviceaccounts kafka-broker-controller

Actions required (post-upgrade):

• Allow independent installation of components (#176, @pierDipi)
  • Remove kafka-broker-config-logging (post-upgrade)
    • kubectl delete -n knative-eventing cm kafka-broker-config-logging

Fix bug

• Update Broker and Trigger status when there is a failure. (#157, @pierDipi)

---

Row markdown ⬇️

## New features

- You can stream HTTP CloudEvents into Apache Kafka using `KafkaSink` objects: ([#177](https://github.com/knative-sandbox/eventing-kafka-broker/pull/177), [#134](https://github.com/knative-sandbox/eventing-kafka-broker/pull/134), [@pierDipi](https://github.com/pierDipi))
- Now you can configure the [server options:](https://vertx-web-site.github.io/docs/apidocs/io/vertx/core/http/HttpServerOptions.html), modifying the config map `config-kafka-broker-data-plane` ([#151](https://github.com/knative-sandbox/eventing-kafka-broker/pull/151), [@slinkydeveloper](https://github.com/slinkydeveloper))
- Now you can configure the [web client options](https://vertx-web-site.github.io/docs/apidocs/io/vertx/ext/web/client/WebClientOptions.html), modifying the config map `config-kafka-broker-data-plane` ([#149](https://github.com/knative-sandbox/eventing-kafka-broker/pull/149), [@slinkydeveloper](https://github.com/slinkydeveloper))

## Actions required (pre-upgrade): 

  - Allow independent installation of components ([#176](https://github.com/knative-sandbox/eventing-kafka-broker/pull/176), [@pierDipi](https://github.com/pierDipi))
    - Remove `kafka-broker-controller`
      - `kubectl delete -n knative-eventing deployment kafka-broker-controller`
      - `kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-controller`
      - `kubectl delete -n knative-eventing clusterrolebindings.rbac.authorization.k8s.io kafka-broker-addressable-resolver`
      - `kubectl delete -n knative-eventing clusterroles.rbac.authorization.k8s.io kafka-broker-controller`
      - `kubectl delete -n knative-eventing serviceaccounts kafka-broker-controller`
    
## Actions required (post-upgrade): 
  - Allow independent installation of components ([#176](https://github.com/knative-sandbox/eventing-kafka-broker/pull/176), [@pierDipi](https://github.com/pierDipi)) 
     - Remove `kafka-broker-config-logging` (post-upgrade) 
       - `kubectl delete -n knative-eventing cm kafka-broker-config-logging` 

## Fix bug 
  - Update Broker and Trigger status when there is a failure. ([#157](https://github.com/knative-sandbox/eventing-kafka-broker/pull/157), [@pierDipi](https://github.com/pierDipi))