问题标签 [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.

0 投票
1 回答
120 浏览

apache-kafka - 无法通过 Kafka REST API 生成 Confluent Kafka 主题

我无法通过 Rest API 代理生成 Kafka 主题。

我有一个正在运行的融合 kafka 集群,我想在其中创建一个主题并使用 REST API 向它生成一条消息。

为此,我遵循了文档并创建了 API 密钥和秘密。

我设法创建主题:

我的问题: 我无法制作该主题(无法通过 Kafka Rest API 制作任何主题):

也尝试过这样的:

IDK这是否与ACL管理有关?目前正在调查中......

0 投票
1 回答
33 浏览

elasticsearch - 如何过滤 ElasticSearch Sink Connector 中的数据?

我正在使用来自融合审计日志集群的数据,并使用弹性搜索接收器连接器为弹性搜索创建索引。我正在获取内部集群的所有环境的数据。我想在弹性接收器连接器级别应用过滤器,以便我可以根据我在连接器级别提供的集群 ID 过滤我的数据。

有谁知道如何在弹性搜索接收器连接器上应用过滤器?

谢谢!

0 投票
0 回答
21 浏览

elasticsearch - Elastic Sink Connector - 如何仅将映射特定数据发送到 Elastic Search?

我正在运行 Elastic Sink 连接器并将数据从 Confluent 审核日志推送到 Elastic 搜索。我已经创建了映射并只指定了必填字段,但是我从合流审计日志中获得了一些不需要的额外字段,因此我没有将它们包含在索引映射中。谁能帮助我使用 Elastic Sink 连接器 - 如何仅将映射特定数据发送到 Elastic Search?

仅供参考:我已经使用 "dynamic":"strict"创建了索引映射

谢谢你的帮助!

0 投票
1 回答
31 浏览

java - 如何允许推送查询连续/一次超过十分钟?

我正在为 ksqlDB 开发一个 java 消费者,它使用 PULL 和 PUSH 查询。

目前,单个推送查询一次最多可以流式传输十分钟,之后如果消费者空闲,服务器将关闭连接。即使流或表发生变化,由于连接超时,我们也无法接收到这些变化。有什么办法可以使这种连接持续存在吗?

0 投票
2 回答
37 浏览

apache-kafka - 使用在 Confluent 上运行的 Kafka 对 Kafka CLI 进行身份验证

我有一个在 Confluent Cloud 上运行的 Kafka 集群,但我无法从 UI 重置提交偏移量。因此,我试图通过 Kafka 的 CLI 进行如下操作:

但是,我遇到了以下错误。我认为这与我如何进行身份验证有关。

0 投票
1 回答
29 浏览

elasticsearch - 如何将数据和指标从 Confluent 发送到 elasticsearch?

要求是将指标和数据从 Confluent 云发送到弹性云。我应该使用logstash还是有什么方法可以实现?已阅读有关 elasticsearch syn 连接器的信息,但有人可以帮我概述所有需要完成的工作吗?

0 投票
1 回答
32 浏览

sql-server - 如何将本地安装的 SQL Server 中的数据流式传输到融合云上的 Kafka 主题,而无需在本地计算机上安装 Kafka

SQL Server 数据库在本地系统中
Kafka 在融合云中配置
本地计算机的操作系统是 Windows 10
有没有办法在本地计算机上不安装 Apache Kafka 将数据从 SQL Server 数据库流式传输到融合云上的 Kafka 主题。