revert RealtimeConsumer.java