问题标签 [confluent-cloud]
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.
apache-kafka - 无法通过 Kafka REST API 生成 Confluent Kafka 主题
我无法通过 Rest API 代理生成 Kafka 主题。
我有一个正在运行的融合 kafka 集群，我想在其中创建一个主题并使用 REST API 向它生成一条消息。
为此，我遵循了文档并创建了 API 密钥和秘密。
我设法创建主题：
我的问题： 我无法制作该主题（无法通过 Kafka Rest API 制作任何主题）：
也尝试过这样的：
IDK这是否与ACL管理有关？目前正在调查中......
elasticsearch - 如何过滤 ElasticSearch Sink Connector 中的数据？
我正在使用来自融合审计日志集群的数据，并使用弹性搜索接收器连接器为弹性搜索创建索引。我正在获取内部集群的所有环境的数据。我想在弹性接收器连接器级别应用过滤器，以便我可以根据我在连接器级别提供的集群 ID 过滤我的数据。
有谁知道如何在弹性搜索接收器连接器上应用过滤器？
谢谢！
elasticsearch - Elastic Sink Connector - 如何仅将映射特定数据发送到 Elastic Search？
我正在运行 Elastic Sink 连接器并将数据从 Confluent 审核日志推送到 Elastic 搜索。我已经创建了映射并只指定了必填字段，但是我从合流审计日志中获得了一些不需要的额外字段，因此我没有将它们包含在索引映射中。谁能帮助我使用 Elastic Sink 连接器 - 如何仅将映射特定数据发送到 Elastic Search？
仅供参考：我已经使用 "dynamic":"strict"创建了索引映射
谢谢你的帮助！
java - 如何允许推送查询连续/一次超过十分钟？
我正在为 ksqlDB 开发一个 java 消费者，它使用 PULL 和 PUSH 查询。
目前，单个推送查询一次最多可以流式传输十分钟，之后如果消费者空闲，服务器将关闭连接。即使流或表发生变化，由于连接超时，我们也无法接收到这些变化。有什么办法可以使这种连接持续存在吗？
apache-kafka - 使用在 Confluent 上运行的 Kafka 对 Kafka CLI 进行身份验证
我有一个在 Confluent Cloud 上运行的 Kafka 集群，但我无法从 UI 重置提交偏移量。因此，我试图通过 Kafka 的 CLI 进行如下操作：
但是，我遇到了以下错误。我认为这与我如何进行身份验证有关。
elasticsearch - 如何将数据和指标从 Confluent 发送到 elasticsearch？
要求是将指标和数据从 Confluent 云发送到弹性云。我应该使用logstash还是有什么方法可以实现？已阅读有关 elasticsearch syn 连接器的信息，但有人可以帮我概述所有需要完成的工作吗？
sql-server - 如何将本地安装的 SQL Server 中的数据流式传输到融合云上的 Kafka 主题，而无需在本地计算机上安装 Kafka
SQL Server 数据库在本地系统中
Kafka 在融合云中配置
本地计算机的操作系统是 Windows 10
有没有办法在本地计算机上不安装 Apache Kafka 将数据从 SQL Server 数据库流式传输到融合云上的 Kafka 主题。