You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We're excited to announce the Kafka Consumer utility, which transparently handles message deserialization, provides an intuitive developer experience, and integrates seamlessly with the rest of the Powertools for AWS Lambda ecosystem.
Key features
Automatic deserialization of Kafka messages (JSON, Avro, and Protocol Buffers)
Simplified event record handling with intuitive interface
Support for key and value deserialization
Support for ESM with and without Schema Registry integration
Proper error handling for deserialization issues
Getting started
To get started, depending on the schema types you want to use, install the library and the corresponding libraries:
You can use Kafka consumer utility to transform raw Kafka events into an intuitive format for processing.
The Handler function can deserialize both keys and values independently based on your schema configuration. This flexibility allows you to work with different data formats in the same message.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
Summary
We're excited to announce the Kafka Consumer utility, which transparently handles message deserialization, provides an intuitive developer experience, and integrates seamlessly with the rest of the Powertools for AWS Lambda ecosystem.
Key features
Getting started
To get started, depending on the schema types you want to use, install the library and the corresponding libraries:
dotnet add package AWS.Lambda.Powertools.Kafka.Jsondotnet add package AWS.Lambda.Powertools.Kafka.Avrodotnet add package AWS.Lambda.Powertools.Kafka.ProtobufProcessing Kafka events
You can use Kafka consumer utility to transform raw Kafka events into an intuitive format for processing.
The
Handlerfunction can deserialize both keys and values independently based on your schema configuration. This flexibility allows you to work with different data formats in the same message.Working with Avro:
Working with Protocol Buffers:
Working with JSON messages:
Error handling
You can handle errors when processing Kafka messages to ensure your application maintains resilience and provides clear diagnostic information.
The Kafka consumer utility integrates with standard C# exception handling patterns.
To learn more about the launch, read the blog post published alongside the release.
🌟New features and non-breaking changes
📜 Documentation updates
🔧 Maintenance
This release was made possible by the following contributors:
@dependabot[bot], @hjgraca and dependabot[bot]
This discussion was created from the release 1.51.
All reactions