我观察到消费者示例未找到错误，在消费者注册时即使消费者示例不是timedout。使用合流api。
以下是阴性测试的步骤：
运行用户注册脚本。
kafka拓扑：3个zk示例（其中2个zk是虚拟值）和1个节点集群（rest代理和代理节点的单个示例）。
当用户注册的脚本正在进行时，请取消脚本并重新运行它。我们已经看到，对于最后注册的使用者，返回instance not found错误。但是，在一些ms之后的日志中，为该消费者注册请求列出了200ok[下面共享的日志中的消费者名称：cgstress\u test1111111111111111116]。
[2018-08-28 09:05:48411]信息http://localhost：8082/v1/consumer/cg压力测试1111111111111111111111111111111111115服务：事务acationid:5 entityid：ed\ U 1 authorized:true allowed：true（io.confluent.kafkarest.resources.securityrestrictions）{“x-nssvc-serviceid”：null，“type”：“api”，“x-nssvc-customerid”：null，“client ip”：“127.0.0.1”，“severity”：“info”，“x-cws-transactionid”：“5”，“message”：{“request”：{“content length”：81，“method”：“post”，“time”：“2018-08-28 09:05:48.409”，“uri”：“mr/v1/consumer/cgstress\u test111111111\u 5”，“entity id”：“ed\u 1”，“user agent”：“python requests/2.11.1”}，“response”：{“status\u code”：200，“time”：“2018-08-28 09:05:48.412”}[2018-08-28 09:05:48，412]信息127.0.0.1---[28/aug/2018:09:05:48+0000]“post/mr/v1/consumer/cgstress\u test111111111\u 4 http/1.1”200 205 19（io.confluent.rest-utils.requests）[2018-08-28 09:05:48，[信息]http://localhost：8082/mr/v1/consumer/cg压力测试1111111111111111111111111111111116服务：传输acationid:6 entityid：ed\ U 1 authorized:true allowed：true（io.confluent.kafkarest.resources.securityrestrictions）{“x-nssvc-serviceid”：null，“type”：“api”，“x-nssvc-customerid”：null，“client ip”：“127.0.0.1”，“severity”：“info”，“x-cws-transactionid”：“6”，“message”：{“request”：{“content length”：81，“method”：“post”，“time”：“2018-08-28 09:05:48.419”，“uri”：“mr/v1/consumer/cgstress\u test111111111\u 6”，“entity id”：“ed\u 1”，“user agent”：“python requests/2.11.1”}，“response”：{“status\u code”：404，“error\u response”：{“message”：“consumer instance not found.”，“error”：40403}，“time”：“2018-08-28 09:05:48.421”}}}[2018-08-28 09:05:48423]info 127.0.0.1---[28/aug/2018:09:05:48+0000]“post/mr/v1/consumer/cgstress\u test111111111\u 5 http/1.1”200 205 15（io.confluent.rest-utils.requests）[2018-08-28 09:05:48，431]信息127.0.0.1---[28/aug/2018:09:05:48+0000]“post/mr/v1/consumer/cgstress\u test111111111111\u 6 http/1.1”404 61 13（io.confluent.rest-utils.requests）[2018-08-28 09:05:49299]警告客户端会话超时，在1501ms内没有收到来自服务器的sessionid 0x0的消息（org.apache.zookeeper.clientcnxn）[2018-08-28 09:05:49，300]信息客户端会话超时，1501ms内未收到服务器关于sessionid 0x0的消息，正在关闭套接字连接并尝试重新连接（org.apache.zookeeper.clientcnxn）[2018-08-28 09:05:49400]信息正在打开到服务器localhost的套接字连接/0:0:0:0:1:32181。不会尝试使用sasl（未知错误）（org.apache.zookeeper.clientcnxn）[2018-08-28 09:05:49400]建立到本地主机的信息套接字连接/0:0:0:0:0:1:32181，启动会话（org.apache.zookeeper.clientcnxn）[2018-08-28 09:05:49403]在服务器本地主机上完成信息会话建立/0:0:0:0:1:32181，sessionid=0x1657f54045b00f3，协商超时=6000（org.apache.zookeeper.clientcnxn）[2018-08-28 09:05:49403]信息zookeeper状态已更改（syncconnected）（org.i0itec.zkclient.zkclient）[2018-08-28 09:05:49404]信息[cgstress\u test111111\u 6\u ubuntuntp-1535447146187-7b4d0350]，每60000毫秒启动自动提交程序（kafka.consumer.zookeeperconsumerconnector）{“x-nssvc-serviceid”：null，“type”：“api”，“x-nssvc-customerid”：null，“client ip”：“127.0.0.1”，“severity”：“info”，“x-cws-transactionid”：“6”，“message”：{“request”：{“content length”：81，“method”：“post”，“time”：“2018-08-28 09:05:46.172”，“uri”：“mr/v1/consumer/cgstress\u test111111111\u 6”，“entity id”：“ed\u 1”，“user agent”：“python requests/2.11.1”}，“response”：{“status\u code”：200，“time”：“2018-08-28 09:05:49.405”}}}[2018-08-28 09:05:49，409]信息127.0.0.1---[28/aug/2018:09:05:46+0000]“post/mr/v1/consumer/cgstress\u test111111111\u 6 http/1.1”200 124 3239（io.confluent.rest-utils.requests）root@ubuntuntp：~/cloudservices/msgrelay#
这和添加的伪zk示例有关吗？