import sys import time #import kafka print('stdout1') print('stderr1', file=sys.stderr) print('stdout2') print('stderr2', file=sys.stderr) sys.stdout.flush() sys.stderr.flush() print('stdout3') print('stderr3', file=sys.stderr) print('stdout4') print('stderr4', file=sys.stderr) time.sleep(10000) output: swh-indexer-journal-client_1 | stderr1 swh-indexer-journal-client_1 | stderr2 swh-indexer-journal-client_1 | stdout1 swh-indexer-journal-client_1 | stdout2