通过超文本传输协议向kafka发布消息
我是新的Kafka，我试图通过超文本传输协议从外部应用程序发布数据，但我找不到这样做的方法。
我已经在kafka中创建了一个主题，并对其进行了测试，以生成和使用消息，但我不知道如何通过http插入/发布消息，我尝试调用以下url来检索主题，但它没有检索任何数据http://servername:2181/topics/
我使用的是cloudera 5.12.1。
共有2个答案
如果主题已经创建，您可以使用API访问它。简单的方法...（参见客户端列表）
或者请参阅连接配置以通过REST（rest.host.name、rest.port参数）管理连接器。但是只有连接器...要在主题中消耗或生成消息，请使用中间件。信息技术更容易。
查看来自ConFluent的开源Kafka REST Proxy。它完全符合您的要求。
您可以将其独立获取，也可以将其作为ConFluent Platform的一部分。
-
我有一个由Python构建的API服务器。我需要一组客户端/计算机通过发出http post请求将数据发送到API服务器。 这里的数据实际上是html内容。（注意：我没有将合法数据转换为HTML/XML格式，数据本身就是我从web上收集的HTML），通常每页约200KB。我正试图通过使用串行/串行和压缩来尽可能减轻网络负载。 我正在考虑通过网络发送原始超文本标记语言。有没有类似序列化html对象的
-
我正在使用GWT和Spring controller来管理http流量。有些请求可能需要很长时间，但我希望在超过给定时间时终止请求。 我如何配置超时Spring。我也使用Apache Tomcat 7.0。我试图在tomcat上inrease最大线程，但有一段时间tomcat工作缓慢，因为请求线程不会死。
-
我只是有一个关于服务中http请求的结构和处理响应的问题。我正在使用Angular2。alpha46 Typescript（刚刚开始测试-我喜欢它…Ps…。感谢所有一直致力于它并通过github作出贡献的人） 因此，采取以下措施： 登录表单。组成部分ts 从这个组件中，我导入了我的userService，它将容纳我的超文本传输协议请求，以登录用户。 使用者服务ts 我想做的是能够处理http请求之
-
我的LogCat： 签名密钥（sw）为https://api.dropbox.com/1/shares/dropbox/a.jpg?oauth_consumer_key=2f2y1dyuqhp58ek 我对http没有太多经验。。 因为httpPost=新的httpPost（sw）；工作正常，这是否意味着基本字符串签名正确？ 还是我错过了什么？
-
我试图禁用我的AngularJS应用程序中的缓存，但它无法使用以下代码： 当我使用
-
我需要检查与vbscript的http连接 我想打给主机看看主机是否有反应 我需要测试到特定端口的连接，为什么不使用url呢 你有解决办法吗？