kafka-rest-atmosphere

卡夫卡-休息-大气 这是一个基于kafka-rest [1]（2.0.1）和大气环境[2]（2.4.x）的代理网关，可将基于Websocket的传输透明地添加到kafka-rest的HTTP REST代理网关。 结果，可以通过HTTP或Websocket以及受大气层支持的其他协议来调用kafka-rest提供的服务。 此外，还可以在同一网关中支持利用Websocket的新服务。 使用Websocket的优点是它支持在单个套接字上进行异步双工通信。 可以在单个连接上异步发送和接收消息。 当为Websocket传输专门设计和优化协议网关时，可以特别利用此优势。 相比之下，此特定网关使用不同的方法，即使用kafka-rest的现有REST服务，并透明地使那些服务能够通过大气使用Websocket和其他协议（例如服务器端事件（SSE））进行调用。 另外，添加了新的消费者服务以支持套接字上的消息