INNER CODE UNIT · Python

my_processor

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

def my_processor(msg: Message) -> Message:
    logging.info(f"Processing message: {msg}")
    return msg

if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    asyncio.run(processor_main(my_processor))

View source record →