问题标签 [confluent-rest-proxy]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

14 问题
Newest
Active
Bountied
318
Unanswered
0 投票
0 回答
68 浏览

postman - 如何将 Avro 记录的逻辑类型十进制值发布到 Confluent Rest Proxy？

我们正在使用 Confluent Rest Proxy 与 Kafka 通信，需要测试各种数据。我们正在使用 Rest Proxy 来允许供应商与我们的 Kafka 系统进行通信。

Avro 模式中的一个字段具有十进制的逻辑类型。为了简单起见，让我们假设这里显示的模式：

通过 Java 生产者编写主题很容易，使用 Avro 工具生成适当的类文件。但是当尝试使用 Rest Proxy 时，我们必须传递如下值：

这是从通过 Java 生产者创建的记录中复制的，然后从主题中下载。但在amount现场，我们希望能够传递一个值，例如123.45. 我们主要使用 Postman 来发送数据。有没有办法使用逻辑十进制字段来做到这一点，而不必先创建和序列化数据以查看表示，例如\u0001ã？

0 投票
0 回答
39 浏览

apache-kafka - kafka rest consumer 上是否有消息时间戳？

  1. 为什么 Rest Consumer 消费消息API的响应中不包含时间戳？将来有计划支持这个吗？
    • 消息时间戳可在 kafka 控制台消费者上使用，生产 V3 API也支持设置时间戳。
  2. 这个PR中的 API 是否仍然有效，因为这里的文档中没有描述用法？

Github问题

0 投票
0 回答
12 浏览

apache-kafka - 通过休息代理汇合将消费者重新加入分组

我正在寻找瓦里安来解决我的问题。在测试中，一个主题有两个分区。为此主题创建了两个消费者，并订阅了它。所有消费者都有一个 UUID，例如 ce24f096-2709-4e0a-946a-61ca6cb64780 和 22ba2c2a-66cb-4da0-97be-2570a731ae2c。对于消费者获取消息，使用像 http://rest-proxy:8082/consumers/consumer-group/instances/consumer1/records 和 http://rest-proxy:8082/consumers/consumer-group/instances/consumer2 这样的网址/记录。在第二个消费者和 MAX_SESSION_TIMEOUT_MS 组重新平衡后，一个消费者从两个分区读取消息正常且可预测。在启动第二个消费者并尝试从主题获取消息后出现错误消费者实例未找到，因为它被删除了。我认为如果第二个消费者不要求 5 分钟，如何不能长时间从组中删除消费者，并重新平衡组。并且可以在可达后得到消息。

0 投票
0 回答
19 浏览

apache-kafka - 在融合云中通过 REST 代理生成记录时出错

我正在尝试生成 AVRO/JSONSCHEMA 记录以融合云 REST 代理。自我管理的 REST 代理服务器已开始指向融合云，请参阅此文档。

我能够征集主题、生成 JSON 记录和消费者 JSON 记录。但是，每当我尝试涉及模式注册表，即 AVRO 记录或 JSONSCHEMA 记录生产时，它都会抛出 40801 错误。

对于生成记录，我参考了 REST 代理快速入门

REST 通话详情：

错误详情：


12345678910