如何在 Kubernetes multipod 部署中使用 spring kafka 处理 Kafka 容器生命周期
我正在使用 Spring kafka 实现，我需要通过 REST API 启动和停止我的 kafka 消费者。为此，我正在使用 KafkaListenerEndpointRegistry endpointRegistry 端点注册表。
我正在尝试使用“camel-azure-storage-datalake-kafka-connector”从 Kafka 连接到 Azure ADLS Gen2 我有一个运行 Docker 的 Linux 机器，其中包含 debezium/zookeeper、debezium/kafka 和 debe...
Kafka Java Consumer Client 是单线程的吗
我们正在开始使用 Kafka， 在阅读本文时 - https://docs.confluence.io/kafka-clients/java/current/overview.html - 它似乎暗示客户端是单线程的。 * 由于这个...
如何使用 kafka msg key 作为 s3 连接器中的分区标准或 我怎样才能获得密钥并将其存储在 s3 对象中 谢谢！
我正在尝试将元数据添加到 kafka 的输出到 S3 存储桶中。 目前，输出只是来自 kafka 主题的消息的值。 我想用下面的东西把它包起来......
即使部署在 kubernetes pod 上，kafka 主题仍然是不可变的吗？
我在 kubernetes pod 上部署了 kafka 主题和模式注册表，我尝试修改/更改 kafka 主题和模式注册表的清单文件，然后模式注册表的行为在
使用 kafka-go 和循环平衡器时，数据始终进入分区 0
我正在使用 kafka-go 库将消息写入 Kafka。我正在使用循环平衡器，但数据始终进入分区 0。我尝试忽略所有消息的分区字段，但是...
我想从Kafka获取数据，此方法成功获取记录但无法传递给变量。这是我的代码 公共无效 subscribeFromKafka() 抛出异常 { 列表结果=新
在我的 SpringBoot Java 项目中，我使用的是 kafka，特别是 ReactiveKafka。我正在更新依赖项，特别是这些依赖项： springboot 2.6.6 -> 3.1.5 弹簧卡夫卡 2.8.0 -> 3.0.11 反应堆-
如何从 Visual Studio 中的 Swagger 文件更新 REST API 客户端
如何从 Visual Studio 中的 Swagger 文件更新 REST API 客户端？右键单击项目时，我通过“添加 -> REST API 客户端”菜单选项创建了 REST API 客户端。看截图
我是容器化新手。我正在尝试设置我的本地环境，我的 java 应用程序想要连接到 Kafka。无法使用 Docker，所以决定使用 Podman。我有三个容器在同一个上运行
Spring Boot 3.1.X及以上版本的Kafka客户端连接问题
我最近将我的一项 Spring Boot 服务升级到 3.1.x，升级后我遇到了 kafka 问题。它似乎无法连接并不断向我提供以下日志。 2024-01-03T06:18...
有没有办法将AWS Cloudwatch日志输入Kafka主题
我正在努力寻找这方面的任何方向。我有一个内部系统可以处理日志以进行监控。我希望从 Cloudwatch 发送错误并在 kafka 主题上发布，其中...
我正在寻找一种从 Kafka 主题中删除（完全删除）已使用记录的方法。我知道有几种方法可以做到这一点，通过更改主题的保留时间或删除...
从 kafka 连接 API 获取任务 ID 以在日志中打印
我有一个kafka连接接收器代码，下面的json作为curl命令传递来注册任务。 如果有人知道如何获取我的连接的任务 ID，请告诉我。例如在
我尝试使用 WPS 从 JIRA REST API 获取数据。我使用 HTTP PROC 调用 JIRA Rest api。 过程http 方法=“获取” url =“http://服务器名称:8080/rest/api/2/search?%str(&)fields=pro...
我有两个具有相同组ID的消费者服务器订阅了相同的主题。 一台 kafka 服务器仅运行一个分区。 据我所知，消息应该在这两个中随机消耗
具有手动偏移提交功能的 Kafka 消费者客户端一次只允许客户端
我目前正在使用一个Java Kafka消费者，它手动提交偏移量（enable.auto.commit = false），我发现即使我生成了多个实例，我发现这样的设置也是如此
使用 Azure Devops REST API 创建交付计划样式规则
我正在尝试使用 Azure Devops REST API 在 Azure Devops 项目中创建交付计划。我使用以下方法来创建相同的。 https://learn.microsoft.com/en-us/rest/api/azure/devop...
如何仅删除已消费的消息以及如何在kafka主题中显示未消费的消息？
我们将一个项目从ActiveMQ迁移到Kafka。 过去我们向很多队列写入了太多的消息，消费完之后，ActiveMQ会自动删除消费的消息。仅未消耗
将 Spring Data Rest 与反应式存储库一起使用时，FluxUsingWhen 无法转换为 Iterable 错误
我配置了一个 ReactiveSortingRepository 来查看 Spring Data Rest 上的反应功能，过去我主要使用 PagingAndSortingRepository 将资源公开为 REST 端点，所以想要...
在结构化流 API 中跨多个集群使用共享 Kafka 主题执行 Spark 作业
我正在开发一个 Spark 项目，我需要在两个不同的集群上运行作业，两个集群都使用相同的 Kafka 主题。我希望这些作业能够有效地共享负载并平衡
我的 REST API 向 MySQL 和 Postman 提供空数据
我是 REST API 和 Spring Boot 的新手。我一直在尝试使用存储员工数据的 STS 和 MySQL 创建 REST API。 一切看起来都很好，但是当我在 Postman 中发布数据时，空行......
因此，我有一个 REST 端点，用于从前端后端 (BFF) 下载文件： @Path("/附件") 公共接口 AttachmentApi { @得到 @Path("/{id}") @Pro...
无法通过PAT令牌调用Azure DevOps Rest Api
我正在尝试使用 Azure DevOps Rest api 将保存在本地目录（桌面）中的 json 文件导入到 Azure DevOps 库变量组。 这是剧本。 $jsonbody = Get-Content -Path "C: ar...
我正在使用 Jira（版本 5）Rest API 来删除版本，就像文档告诉我的那样，我通过 moveFixIssuesTo 和 moveAffectedIssuesTo 将问题从已删除的版本转移到 o...
我正在尝试使用 keycloak REST API 删除用户会话， 但获取 403 禁止 Http 状态代码。 我正在将令牌和 cookie 传递到标头中，如果我遗漏了某些内容，请告诉我...
我想使用不来自java的iceberg（或者显然使用java的python）。客户端的API文档声称它支持REST目录。这和尼斯湖水怪目录一样吗？
我面临的挑战是注册 dj-rest-auth（一个为 Django 设计的身份验证组件）时。当用户注册时，会自动发送一封电子邮件以验证他们的电子邮件地址....
Python KafkaTimeoutError：等待未来超时
我正在使用 Kafka 将日志发送到主题。发送消息时，我总是收到此错误 消息：“测试日志” 参数：() --- 记录错误 --- 回溯（最近一次调用最后一次）： 文件“...
我目前正在为学校项目开发一个REST API，到目前为止一切都很好。我们才刚刚开始，但我们面临一些困难： / 路线为我们提供了端点列表，并且...
Apache Spark Structured Streaming 中 Spark UI 上的查询和阶段卡住了
我在 EMR 集群 (6.14) 上使用 Apache Spark Structured Streaming (3.1.2)。 Spark 结构化流将数据从 Apache Kafka 流式传输到 Delta Lake 表。当我打开 Spark UI 时，我看到以下内容
我有一个带有 REST 端点的 Spring Boot 应用程序，还有一个 VueJS 应用程序（以及一些 Vue 路由器逻辑）。问题是，每当我点击 http://localhost:8080/information 时，我...
debezium 日期/时间字段值超出范围：0000-12-30T00:00:00Z
我们使用 Debezium 将数据同步到 在源表中我们有列timestamptz start_at，当值为0时start_at='0001-01-01 00:00:00.000000 +00:00'，但是当我们检查kafka中的数据时，它是
我一直在尝试在 keycloak 21.1 中实现这个自定义端点： EndopintFactory.java 文件 包org.keycloak.extension.authenticator； 导入 org.keycloak.Config； 导入 org.keycloak.models.
Azure 逻辑应用程序限制最大等待运行次数 - 如果超出限制会发生什么？
我有一个 Azure 逻辑应用程序（标准）来处理文件。 LA 将由 Blob 存储触发器 (InApp) 触发，并将文件内容发送到 REST 接口。为了防止 REST 接口
Groovy 抛出 可能的解决方案：解析 LinkedHashMap 时出现 parseText(java.lang.String) 错误
我正在尝试检查kafka输出消息中是否存在该密钥，如果存在则进行进一步的操作。 卡夫卡主题的输出消息如下 [“随机名称_547hcg”：{ “访问_...
我有一个使用 AWS 上的 MSK 集群的 kafkaStreams 应用程序。 我需要清理状态存储（在我的应用程序中使用一些 KTable 后创建）。 我找不到任何方法来访问文件系统......
自消息发布或 sinse 服务器启动以来，kafka 是否计数 log.retatantion
如果我将 log.retantion 设置为 24 小时，则在 1.1.24 15:30 发布了一条消息。 然后服务器宕机了25小时，24年1月16日16:30再次启动，消息会立即删除吗...
如何在没有管理员帐户的情况下通过 REST 获取 Keycloak 用户
有没有一种方法可以通过 REST 获取 Keycloak 领域上的用户列表，而无需使用管理员帐户？也许可以从管理控制台分配某种角色？寻找任何想法。 现在我是你...
通过 Azure Devops REST API 运行构建管道时，分支始终默认为 Master
我已经设置了一个 powershell 脚本，该脚本通过 REST API 在 Azure Devops 中运行构建管道，这可以工作，但始终将分支指定为主分支，即使我指定了不同的分支也是如此。 我...
假设最初我们有一个包含 3 个分区的主题和一个包含 3 个消费者的消费者组，从该主题进行消费。如果我们在消费者组中再添加一个消费者，分区会重新平衡吗
我的 Spring 批处理由 Rest 端点触发。我正在寻找一次仅运行一个作业实例的解决方案。
使用 WP Rest API 创建媒体时如何指定“alt”或“caption”等字段
我可以使用以下代码更新媒体： 函数createMedia($urlImage,$title) { 全局$用户名WP; 全局$passwordWP; $rest_api_url = "https://www.example.com/wp...
我有一个运行nestjs框架的nodejs REST API后端，使用typeORM作为我的实体的ORM。 来自 C#/Entity Framework 背景，我非常习惯将 Dtos 映射到数据...
我正在尝试使用 PayPal REST API 创建订单/交易，但无法让 Apple Pay 和 Venmo 正常工作。根据他们的官方文档，Apple Pay 和 Venmo 但是...
这是我的第一个问题。我是 SCCM 连接的新手，所以我真的不知道发生了什么。我参考了以下程序集： 使用 Microsoft.ConfigurationManagement。
我已经创建了 Spring boot 应用程序并使用 REST API 开发并部署在具有 DNS 名称的其他服务器上。 @FeignClient(url="${env.app.crm.url}", value=“crm-feign-client...
Saxon XSLT 可以将 XML 保存到 eXist-db 吗？
Saxon XSLT 可以将 XML 保存到 eXist-db 吗？我搜索了文档和论坛，但找不到任何明确记录的内容。我可以使用 doc('http://localhost:8080/exist/rest...
是否有任何快捷方式或 kubectl 命令或 REST API 调用来仅获取工作节点列表。 （不包括主节点） 更新： 对于高手我们可以这样做： kubectl 获取节点 --