若不启用订阅高可用功能,客户端只需订阅Raft组中任意一个数据节点上的高可用流数据表,并启用订阅的自动重连功能(即把subscribeTable的reconnect参数设置为true)。Leader上的高可用流数据表会向订阅端发布数据。如果Raft组中的Leader宕机,系统会选举出新的Leader继续发布数据,客户端会自动切换订阅到新Leader上的高可用流数据表。若开启了订阅端高可用,即raftGroup指定了Raft组。则只能在leader上执行订阅。
你的代码设置了raftGroup参数,因此需要到leader上执行订阅。可以用getStreamingLeader(2) 看一些leader节点是哪个。