INNER CODE UNIT · Python

my_output

redpanda-data/connect · internal/rpcplugin/pythontemplate/output/main.py:7

async def my_output(config: Value, messages: AsyncIterator[Message]):
    _ = config
    async for message in messages:
        print(f"Outputting message: {message}")

if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    asyncio.run(output_main(my_output))

View source record →