tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group¶

Example Airflow DAG for Google Cloud Managed Service for Apache Kafka testing Topic operations.

Attributes¶

`producer`()	Produce and submit 10 messages
`consumer`(message)	Take in consumed messages and print its contents to the logs.

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.ENV_ID[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.PROJECT_ID[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.DAG_ID = 'managed_kafka_consumer_group_operations'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.LOCATION = 'us-central1'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CLUSTER_ID = ''[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CLUSTER_CONF[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.TOPIC_ID = ''[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.TOPIC_CONF[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CONSUMER_GROUP_ID = ''[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CONNECTION_ID = 'connection_managed_kafka_consumer_group_operations_Uninferable'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.PORT = '9092'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.BOOTSTRAP_URL[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.log[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.producer()[source]¶: Produce and submit 10 messages

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.consumer(message)[source]¶: Take in consumed messages and print its contents to the logs.

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.create_cluster[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.test_run[source]¶