问题标签 [confluent-cloud]

如何在使用主题时根据环境过滤 Confluent Cloud 集群审计日志：confluent-audit-log-events in spring boot application？

我正在使用骆驼路线从审计主题中消费。

我正在尝试从https://github.com/aws-samples/amazon-kinesis-data-analytics-java-examples repo 运行 KafkaGettingStartedJob。与 AWS MSK 连接时运行良好。我在使用 Confluent Cloud 运行时遇到了问题。我已将其修改为仅从一个主题读取数据并写入另一个主题。我正在使用以下属性：

在运行 flink 作业时，我在作业开始 1 分钟后收到以下错误：

我一直在阅读有关 Confluent Cloud（不是 Confluent 平台）的文档，但找不到管理网络和请求配额的方法。Confluent Cloud 不支持此功能吗？

我的 .net 生产者应用程序出现如下问题。

auto.enable.schemas=false即使在 .NET Producer APP 中设置了选项，Schema 也会在 Confluent-Cloud 中注册。

寻求帮助来解决它。

谢谢 ：）

我正在尝试使用 CLI（版本 1.38.0）配置一个专用的Kafka 集群ccloud，但我没有在ccloud kafka create cluster命令中看到创建私有链接的选项：

但是，当我尝试通过 Confluent UI 进行配置时，我可以在网络部分看到创建私有链接的选项。

CLI不支持此功能ccloud还是我遗漏了什么？

我有一个在 Azure k8s 中运行的服务，并尝试使用来自 Confluent Cloud（Kafka SaaS 解决方案）的消息。

获取以下错误跟踪：

相同的配置适用于本地 k8s 集群和配置的 Apache Kafka 防火墙规则。关于可能原因的任何想法？

我正在尝试为我们的融合云安装 MQ 源和接收器连接器。我已经为本地 apache kafka 完成了此操作，但对云执行相同操作似乎有所不同。按照融合文档说我需要在我的本地安装一个平台，我这样做了，然后运行一个 confluent-hub 安装，它确实在我的本地安装连接器，然后将 json 用于分布式实例。我的问题是当我运行 json 时，它说找不到 mq 的类，我试图将 CLASSPATH 指向 jars 所在的目录，但仍然得到相同的错误。我如何成功运行它？

还想了解在本地安装连接器将如何应用于我的云集群？不知道我错过了什么！

两周前，我能够在 Confluent.Cloud 平台中使用 ExtractTopic 转换创建 ElasticSinkConnector。但是，该功能现在不可用。他们为什么要在 Confluent.Cloud 中删除该功能？

否则，我们是否有其他可用的选项与 ExtractTopic 等效？

有两个kafka主题

• 消息
• 图片

新闻主题中的消息可以具有以下图像 ID 列表

图片主题中的消息如下所示

我正在尝试加入这两个流以填充包含所有图像细节的最终新闻消息。

我尝试使用groupBy和聚合如下

但正如预期的那样，上面的代码聚合了新闻的所有图像

当作者第一次用两张图片发布新闻时，一切顺利，我们可以看到下面的输出

当作者重新发布只有 image-3 的文章时，它正在输出所有三个图像（这就是聚合器） news-1 ：[image-1，image-2，image-3]

我正在寻找任何其他替代方法来加入新闻和图像，并在重新发布新闻 news-1 时覆盖以前的值：[image-3]

我最近开始研究kafka-streams和 joins。我只是想知道是否有任何简单的方法可以在 kafka-streams 中实现多个外键的外键连接

员工话题

部门主题

应该转化为

联合输出

编辑1：

尝试解决方案1：

但是上面的代码聚合了事件中的所有部门。如果任何员工的部门发生变化，我仍然会在汇总的国有商店中看到旧部门。我只想随时查看员工的最新部门。

尝试解决方案2：

下面一个完美的作品！但我觉得下面一个不是一个有效的解决方案，因为它不使用任何 kafka 流连接。