Skip to main content

Changelog

Connectors Changelog

Keep track of updates and enhancements to our connectors.

12 posts tagged with "Kafka"

Publish and consume messages from Apache Kafka event streams.

View All Tags

Kafka (2026-11-03)

Published the component as an npm package, so code-native integrations can install it and call its actions, triggers and data sources from code with TypeScript types

Kafka (2026-10-08)

Added Amazon MSK IAM authentication, along with connection and trigger updates:

  • Added the IAM Access Key and Secret and IAM Role ARN connections for Amazon MSK clusters that use IAM access control
  • Added a required AWS Region dropdown to the IAM Access Key and Secret and IAM Role ARN connections for selecting the region of the Amazon MSK cluster
  • Updated the Schema Registry API Key field on the Basic Authentication connection to a masked password field
  • Updated the Kafka Consumer trigger to group From Beginning, Auto Commit, and Deserialize Keys as Avro into a Consumer Options structured object, and to show Session Timeout (ms) and Heartbeat Interval (ms) as top-level inputs again in place of the Session Timing group
  • Updated the Kafka Consumer trigger to fail the run when the consumer cannot start, such as when it cannot join its consumer group, and to reject a Max Messages value below 1
  • Updated the Publish Messages action to close its broker connection when sending messages fails

Kafka (2026-08-13)

Enhanced component capabilities:

  • Updated the Select Topic data source to read the cluster address from the Brokers input so topic dropdowns resolve (breaking: the data source's Broker input was removed, so previously configured values must be re-entered)
  • Grouped the Session Timeout and Heartbeat Interval inputs on the Kafka Consumer trigger into a Session Timing structured object
  • Added output schemas across all actions for improved field mapping during configuration
  • Added inline action calling support across all actions for improved example output during configuration

Kafka (2026-07-30)

Added Confluent Schema Registry Avro deserialization support for the Kafka Consumer trigger:

  • Automatically decoded consumed Avro-encoded message values to JSON objects
  • Added optional Deserialize Keys as Avro input for key deserialization