我正在使用rest api从confluent云上的kafka实例获取主题 我正在使用下面的curl命令 curl "http://(myhost):9092/topics/(topicname)"--output op.txt 但是我在op.txt中得到了垃圾价值，比如 "U^C^C^@^B^BP" 对此有什么解决方案吗？
浏览 20提问于2020-11-05得票数 0
const handleJson = (res) => res.json();
fetch(`${API_URL}/task1/get/${Id}`, options).then(handleJson), ]); 在此示例中，我将使用promise
浏览 23提问于2020-12-23得票数 0
回答已采纳
1回答
我正在研究集装箱化应用程序，其中前端应用程序调用HTTP请求到API网关。API网关收到的请求数据通过Kafka转发给Micro服务。但我必须将响应作为响应发送回API网关，并返回到前端应用程序。请问如何通过Kafka实现API网关和micron服务的同步请求和响应？ 我尝试过Producer和Consumer，这就像Fire一样，忘记了我无法响应请求的地方。 提
浏览 127提问于2020-05-02得票数 1
我们的微服务使用JDK 8，Spring Cloud Stream API with Spring Boot 1.5.2 messages将消息生成到Kafka队列。对于Consumer API，我们使用Spring Kafka 1.1.2.RELEASE，特别是@KafkaListener。消息类型为应用程序json在JDK 8中使用普通Apache
浏览 0提问于2017-06-20得票数 0
1回答
Laravel猜谜解析
、、、、
我正在与外部API进行通信，并以这种方式获取响应：这部分运行得很好，我可以在Chrome检查器返回的值中看到。我面临的问题是在响应中获取一个特定值。我用3个值嵌套了JSON：aggregations (值数组)，hits (值数组)，total (数字)。
浏览 0提问于2017-07-09得票数 0
回答已采纳
1回答
现在，在这个API的执行过程中，我正在执行一些操作，我需要将其作为API的响应发送。"Database": [ "data 1 inserted", ], "Topic 1 created",
浏览 1提问于2017-08-12得票数 0
回答已采纳
我花了一些时间发现我的Go应用程序连接到Kafka 0.11集群使用的是旧的0.8.2版本的库，它在响应中缺少时间戳值。
然后我发现Kafka 0.11.x API/版本不受支持(但他们正在努力)。首先是在我的应用程序中明确设置所需的版本。其次是“调优”Sarama代码以使用版本0.10.x作为最低版本，使我能够使用所有0.10.x API</e
浏览 5提问于2017-09-25得票数 0
2回答
我通过Rest代理(在Docker容器中)使用Kafka版本2.2.0cp2。我需要消费者始终只读一条消息。我在文件/etc/kafka/consumer.properties中设置了值max.poll.records=1，如下所示：max.poll.records在其他配置中设置此值也不会产生任何结果。
浏览 8提问于2019-10-31得票数 4
消费者收到一个Kafka流，流中的消息需要基于一些Validator Micro服务和Enricher API调用进行丰富和验证。它还将消息持久化到数据库中。流程是这样的- Kafka Stream consumer ->每个消息->调用Rule Validator Rest API ->调用富API ->通过持久化REST API保存到数据库。因为所有的REST调用都是同步的</em
浏览 0提问于2020-03-22得票数 1
在我的工作中，我被要求使用它创建一个POC，并将它集成到Spring中，并在MongoDB上保存信息(因为我们需要按需检索信息，我认为这将是最好的方法)。现在，代码正在工作，但我想改进它，特别是Controller部分，以及您可以为改进这一点而提出的任何额外评论。这是我的项目的结构：KafkaConfiguratorimport java.util.Map;
浏览 0提问于2020-04-02得票数 2
我使用LIBRDKAFKA C库开发了一个RD Kafka客户端。LIBRDKAFKA库公开了set_config API，以设置消费者和生产者句柄的配置值。大约有数百个可供设置的信任，对于set_congig来说，每一个值都变得非常乏味。重要的是，它不能有效地设置代码本身，因为在这里，我们没有根据不同平台调整配置值的灵活性，因为它需要重新构建RD Kafka客户端。
浏览 4提问于2017-09-15得票数 0
回答已采纳
Error: REQUEST_TIMED_OUT (org.apache.kafka.clients.producer.internals.Sender:616)[2022-03-03 08:31:28,800Error: REQUEST_TIMED_OUT (org.apache.kafka.clients.producer.i
浏览 5提问于2022-03-03得票数 0
我正在向外部API发送HTTP请求，但是不知道如何访问它的内部主体。所有的表演都在Lambda上进行。例如： console.log(res);我知道如何获取res.headers、如何获取res.statusCode、如何获取res.status等，但不知道如何获取所需的数据。console.log(
浏览 2提问于2017-02-17得票数 0
在这种情况下，我们将丢失用户请求，并且服务将不会对这些情况返回任何响应。我目前的架构可以处理多达1000个并发请求，没有任何问题。为了避免这个问题，我计划使用Kafka存储和检索所有的请求和响应。因此，我想使用Kafka来管理我所有web服务的请求和响应，并包含一个单独的服务或web套接字来处理所有请求，并将响应再次存储到Kafka。在这种情况下，如果我的核心进程docker崩溃或重新启动。它在任何
浏览 1提问于2017-11-09得票数 0
3回答
我对棱角很陌生，这可能是个愚蠢的问题。我正在尝试获取一个api响应并将其保存到一个数组中。我的API响应看起来如下： { "name": "name1", "t1p": {
浏览 0提问于2019-07-31得票数 2
回答已采纳
我想用NodeJS和Kafka构建一个API，它可以将一个偏移量和一个主题作为输入，并输出从偏移量开始的前10条消息。我在和中尝试了这种方法。var Kafka
浏览 7提问于2016-04-28得票数 1
2回答
我们正在Scala中开发一个Kafka应用程序，它从Kafka主题读取请求，处理请求，并将响应写入Sink Kafka主题。transformToResponseSchema) }
为了能够使用transformToResponseSchema，我们有一个键>值的内存映射，需要按计划从第三方API中更新，以便能够处理请求并将请求转换为<e
浏览 7提问于2022-07-11得票数 0
1回答
);//I am getting details from APIDetailsField detail =detail.setValue(List<Response> response);return (List<DetailsField> )detail);基本上，我是从res获取细节，但我需要将res详细信息设置为
浏览 2提问于2022-10-19得票数 -1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号