• A bug was fixed in the consolidated KafkaChannel where subscriptions would show up in the channel's status.subscribers before the dispatcher becomes ready to dispatch messages for those subscribers.
  • Consolidated KafkaChannel dispatcher's horizontal scalability works now seamlessly with reconciler leader election. (#182, @devguyio)
• Adding new optional field named sasltype to default kafka-secret to enable other Kafka SASL Methods than PLAIN. Supports SCRAM-SHA-256 or SCRAM-SHA-512. (#332, @larhauga)
• Adding tls.enabled flag for public cert usage and allowing skipping CA/User certs and key (#359, @matzew)
• KafkaSource and KafkaChannel will be default use the config-leader-election CM for configs (#231, @matzew)
• Removed support for pooling Azure EventHub Namespaces and now only support a single Namespace/Authentication which limits Azure EventHub usage to their constrained number of EventHubs (Kafka Topics). (#297, @travis-minke-sap)
• The "distributed" KafkaChannel configuration YAML now includes the KafkaChannel WebHook which provides conversion. (#187, @travis-minke-sap)
• The KafkaSource will be installed in the knative-eventing namespace, and the old controller in knative-sources is scalled to 0 (#224, @matzew)
• Add a new alternative KafkaSource implementation in which a single global StatefulSet handles all KafkaSource instances. (#186, @lionelvillard)
• It is now possible to define Sarama config defaults for KafkaSource in config-kafka configmap with a sarama field. (#337, @aliok)
• It is now possible to define Sarama config defaults for consolidated channel in config-kafka configmap with a sarama field. (#305, @aliok)
• KafkaChannel CustomResourceDefinition now uses apiextensions.k8s.io/v1 APIs (#132, @pierDipi)
• The KafkaSource scale subresource can now be used to scale up and down the underlying deployment (#138, @lionelvillard)
• Defaulting the connection args to a sane value (#353, @slinkydeveloper)
• Fix concurrent modification of consumer groups map, which causes undefined behaviours while running reconciliation in the dispatcher (#352, @slinkydeveloper)
• Fix crash in Kafka consumer when a rebalance occurs (#263, @lionelvillard)
• Fix race on error channel in consumer factory (#364, @slinkydeveloper)
• The KafkaSource dispatchers now expose metrics and profiling information (#221, @lionelvillard)
• The consolidated KafkaChannel now relies by default on SyncProducer for safer event production. (#181, @lionelvillard)