testConsumerInternalClose org.gecko.core.pushstream.distributed.DistributedConsumerTest

publish data: test0
publish data: test1
publish data: test2
publish data: test3
publish data: test4
publish data: test5
publish data: test6
publish data: test7
publish data: test8
publish data: test9