Fixing NPE in BaseStreamingClient.java related to Faust streaming