airflow.providers.amazon.aws.hooks.msk¶

This module contains Amazon Managed Streaming for Apache Kafka hook.

Classes¶

MskHook

Create an authenticated Amazon Managed Streaming for Apache Kafka client.

Module Contents¶

class airflow.providers.amazon.aws.hooks.msk.MskHook(*args, **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Create an authenticated Amazon Managed Streaming for Apache Kafka client.

Additional arguments, such as aws_conn_id or region_name, are passed to AwsBaseHook. Use conn or get_conn() to access the underlying boto3.client("kafka") directly.

confluent_token(config_str)[source]¶

Generate an Amazon MSK IAM token for a confluent_kafka OAuth callback.