我有一个用例，它涉及从多个http端点提取/流式传输数据，超过100个。
我有一个独立的java应用程序，可以使用ning async client http库管理多达30多个客户端请求，但我想知道如何扩展它以处理更多的请求。
用例是从端点拉取数据并将它们推入kafka队列（类似于jms队列），以便由storm拓扑进行处理。我一直关注的一点是如何最有效地将http端点数据首先放入kafka队列。
谢谢