tests.system.apache.kafka.example_dag_hello_kafka

属性

default_args

consumer_logger

t0

test_run

函数

load_connections()

producer_function()

consumer_function(message[, prefix])

consumer_function_batch(messages[, prefix])

await_function(message)

hello_kafka()

模块内容

tests.system.apache.kafka.example_dag_hello_kafka.default_args[source]
tests.system.apache.kafka.example_dag_hello_kafka.load_connections()[source]
tests.system.apache.kafka.example_dag_hello_kafka.producer_function()[source]
tests.system.apache.kafka.example_dag_hello_kafka.consumer_logger[source]
tests.system.apache.kafka.example_dag_hello_kafka.consumer_function(message, prefix=None)[source]
tests.system.apache.kafka.example_dag_hello_kafka.consumer_function_batch(messages, prefix=None)[source]
tests.system.apache.kafka.example_dag_hello_kafka.await_function(message)[source]
tests.system.apache.kafka.example_dag_hello_kafka.hello_kafka()[source]
tests.system.apache.kafka.example_dag_hello_kafka.t0[source]
tests.system.apache.kafka.example_dag_hello_kafka.test_run[source]

此条目是否有帮助？