class SelfManagedKafkaEventSource

Language	Type name
.NET	Amazon.CDK.AWS.Lambda.EventSources.SelfManagedKafkaEventSource
Go	github.com/aws/aws-cdk-go/awscdk/v2/awslambdaeventsources#SelfManagedKafkaEventSource
Java	software.amazon.awscdk.services.lambda.eventsources.SelfManagedKafkaEventSource
Python	aws_cdk.aws_lambda_event_sources.SelfManagedKafkaEventSource
TypeScript (source)	aws-cdk-lib » aws_lambda_event_sources » SelfManagedKafkaEventSource

Implements IEventSource

Extends StreamEventSource

Use a self hosted Kafka installation as a streaming source for AWS Lambda.

Example

import { SelfManagedKafkaEventSource, AuthenticationMethod } from 'aws-cdk-lib/aws-lambda-event-sources';
import { StartingPosition, Function } from 'aws-cdk-lib/aws-lambda';
import { ISecret } from 'aws-cdk-lib/aws-secretsmanager';

// With provisioned pollers and poller group for cost optimization
declare const myFunction: Function;
declare const kafkaCredentials: ISecret;
myFunction.addEventSource(new SelfManagedKafkaEventSource({
  bootstrapServers: ['kafka-broker1.example.com:9092', 'kafka-broker2.example.com:9092'],
  topic: 'events-topic',
  secret: kafkaCredentials,
  startingPosition: StartingPosition.LATEST,
  authenticationMethod: AuthenticationMethod.SASL_SCRAM_512_AUTH,
  provisionedPollerConfig: {
    minimumPollers: 1,
    maximumPollers: 8,
    pollerGroupName: 'self-managed-kafka-group', // Group pollers to reduce costs
  },
}));

Initializer

new SelfManagedKafkaEventSource(props: SelfManagedKafkaEventSourceProps)

Parameters

• props SelfManagedKafkaEventSourceProps

Methods

Name	Description
bind(target)	Called by lambda.addEventSource to allow the event source to bind to this function.

---

bind(target)

public bind(target: IFunction): void

Parameters

• target IFunction

Called by lambda.addEventSource to allow the event source to bind to this function.