INNER CODE UNIT · Python

my_input

redpanda-data/connect · internal/rpcplugin/pythontemplate/input/main.py:6

async def my_input(config: Value):
    _ = config
    yield Message(payload="Hello")
    yield Message(payload="World")
    yield Message(payload="!")

if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    asyncio.run(input_main(my_input))

View source record →