Fix Beam Samza scaling

Fix Samza Container with scale > 1 :

javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=kafka_admin_consumer-ucapplication-1

Log from current implementation: uc1-beam-samza-error.log

Log from Jans implementation: uc1-beam-samza-jan2-error.log