Feature request: Kafka Parser support

[ran-isenberg]

Use case

see #1484

When using a Kafka event source either from self-managed Apache Kafka or Amazon MSK there should be a relevant data class for easy iteration/decoding.

Such functionality is implemented already in aws-lambda-go and in aws-lambda-java-libs.

Solution/User Experience

@event_parser(model=MyALambdaKafkaBusiness, envelope=envelopes.KafkaEnvelope)
def handle_lambda_kafka_with_envelope(event: List[MyALambdaKafkaBusiness], _: LambdaContext):
    assert event[0].key == "value"
    assert len(event) == 1


@event_parser(model=KafkaEventModel)
def handle_kafka_event(event: KafkaEventModel, _: LambdaContext):
    return event

Alternative solutions

No response

Acknowledgment

• This feature request meets Lambda Powertools Tenets
• Should this be considered in other Lambda Powertools languages? i.e. Java, TypeScript

[github-actions]

This is now released under 1.29.0 version!

[github-actions]

This is now released under 1.29.1 version!