Make PubSubWebSocketInputOperator topic configurable.
Encoder was moved.
fixed the mr monitor app
Merge branch 'tweise-dt-dev' into dt-dev