我正在尝试使用“camel-azure-storage-datalake-kafka-connector”从 Kafka 连接到 Azure ADLS Gen2 我有一个运行 Docker 的 Linux 机器，其中包含 debezium/zookeeper、debezium/kafka 和 debe...
如何在 Kubernetes multipod 部署中使用 spring kafka 处理 Kafka 容器生命周期
我正在使用 Spring kafka 实现，我需要通过 REST API 启动和停止我的 kafka 消费者。为此，我正在使用 KafkaListenerEndpointRegistry endpointRegistry 端点注册表。
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 反应堆-
我是容器化新手。我正在尝试设置我的本地环境，我的 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 主题中删除（完全删除）已使用记录的方法。我知道有几种方法可以做到这一点，通过更改主题的保留时间或删除...
我的 VS CODE 屏幕截图 代码是正确的，没有错误。我已经安装了最新版本的 Node js，并且没有更新显示 Node Index.js 仍然没有在术语中运行...
我有两个具有相同组ID的消费者服务器订阅了相同的主题。 一台 kafka 服务器仅运行一个分区。 据我所知，消息应该在这两个中随机消耗
具有手动偏移提交功能的 Kafka 消费者客户端一次只允许客户端
我目前正在使用一个Java Kafka消费者，它手动提交偏移量（enable.auto.commit = false），我发现即使我生成了多个实例，我发现这样的设置也是如此
如何仅删除已消费的消息以及如何在kafka主题中显示未消费的消息？
我们将一个项目从ActiveMQ迁移到Kafka。 过去我们向很多队列写入了太多的消息，消费完之后，ActiveMQ会自动删除消费的消息。仅未消耗
我阅读了一些 Docker 和 Node.js 最佳实践文章，例如https://github.com/nodejs/docker-node/blob/main/docs/BestPractices.md 或使用
在结构化流 API 中跨多个集群使用共享 Kafka 主题执行 Spark 作业
我正在开发一个 Spark 项目，我需要在两个不同的集群上运行作业，两个集群都使用相同的 Kafka 主题。我希望这些作业能够有效地共享负载并平衡
我有这个curl命令，我需要在node js中编写： 卷曲-X POST \ https://image.adobe.io/pie/psdService/renditionCreate \ -H“授权：不记名$令牌”\ -H“x-api-...
Node Sass 版本 9.0.0 与 ^4.0.0 不兼容
我的应用程序中没有安装node-sass或sass包。但我一直收到这个错误 ./src/scss/styles.scss 中的错误（./node_modules/@angular-devkit/build-angular/src/angular-cli-files/plu...
当我尝试在 Visual Code Studio 上运行“ts-node index.ts”等代码时，它显示错误消息
/usr/local/lib/node_modules/ts-node/src/index.ts:857 const DiagnosticText = formatDiagnostics(诊断，diagnosticsHost); 类型错误：formatDiagnostics 不是函数 在 createTSError (/usr/loc...
信息：node_modules/node-expose-sspi/dist/sso/client.d.ts:3:8 - 错误 TS1192：模块“http”没有默认导出。 在我安装了node-expose-sspi之后，然后编译了Angular项目（v...
Node Express.js 应用程序在本地运行良好，但在 Docker 中显示“无法获取/”
我在 Node 应用程序中定义了一个 Express.js 服务器，如下所示： const express = require('express') const SignRequest = require('./SignRequest/lambda/index.js') const VerifyResponse = require('./
使用 Node Express 托管网站无法与 Windows 任务计划程序一起使用
我编写了一个简单的网站，并使用 Node Express 托管它。 const express = require('express') 常量应用程序 = Express() app.use(express.static('./')) app.listen(7100, () => { console.log('开始'...
node/nodemon 中是否有对 typescript 的源映射支持？
我有一个用 typescript@2 编写的节点项目。 我的 tsconfig 将 sourceMap 设置为 true 并生成 *.map.js 文件。当我通过 node 或 nodemon 执行转译的 *.js JavaScript 文件时，我...
Python KafkaTimeoutError：等待未来超时
我正在使用 Kafka 将日志发送到主题。发送消息时，我总是收到此错误 消息：“测试日志” 参数：() --- 记录错误 --- 回溯（最近一次调用最后一次）： 文件“...
在使用 Express 的 Node app.js 之后，控制台未显示“服务器启动”
当我在终端上插入 Node app.js 时，我没有在控制台上收到启动服务器：3001 消息。 我的 app.js 文件内容： var createError = require('http-errors'); var express = require('express'); 变量路径 =
Apache Spark Structured Streaming 中 Spark UI 上的查询和阶段卡住了
我在 EMR 集群 (6.14) 上使用 Apache Spark Structured Streaming (3.1.2)。 Spark 结构化流将数据从 Apache Kafka 流式传输到 Delta Lake 表。当我打开 Spark UI 时，我看到以下内容
在 Docker 中的 Ubuntu 上安装最新版本 Node (v20) 的说明不起作用？
我只是按照说明在 Ubuntu 上的 docker 中安装了最新版本的 Node (v20)，在我的 Dockerfile 中包含以下内容： 来自 --platform=linux/amd64 ubuntu:22.04 运行 apt-get update 运行 apt-get...
debezium 日期/时间字段值超出范围：0000-12-30T00:00:00Z
我们使用 Debezium 将数据同步到 在源表中我们有列timestamptz start_at，当值为0时start_at='0001-01-01 00:00:00.000000 +00:00'，但是当我们检查kafka中的数据时，它是
为什么ElasticSearch将主分片和副本分片放在同一主机上？
这是添加到现有集群测试中的新主机，触发了重新平衡过程。 两个节点node-5、node-6位于新物理主机中。 对于每个分片，只有一个主分片...
为什么ElasticSearch将主分片和副本分片放在同一主机上？
这是添加到现有集群测试中的新主机，触发了重新平衡过程。 两个节点node-5、node-6位于新主机中。 对于每个分片，只有一个主分片和一个
请帮助我。这是我下面关于discord.js 聊天机器人的代码 const fetch = require("node-fetch"); const {ChannelType} = require("discord.js"); client.on('messageCreate...
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再次启动，消息会立即删除吗...
假设我们有要转换的 XML： 测试 / 假设我们有要转换的 XML： <?xml version="1.0" encoding="UTF-8"?> <node> <field1>test</field1> <field2>/</field2> <field3>test2</field3> <field4>/<field4> </node> 我想使用 XSLT 1.0 对其进行转换，以便复制整个结构和所有值，除了具有值“/”的元素。 到目前为止，我已经找到了这个，我认为这离我需要的并不遥远，但它还没有工作。 <xsl:transform xmlns:xsl="http://www.w3.org/1999/XSL/Transform" version="1.0"> <xsl:strip-space elements="*"/> <xsl:output indent="yes"/> <xsl:template match="@*|node()"> <xsl:copy> <xsl:apply-templates select="@*|node()"/> </xsl:copy> </xsl:template> <xsl:template match="//text()='/'" /> </xsl:transform> 所以我期望的输出是这样的： <?xml version="1.0" encoding="UTF-8"?> <node> <field1>test</field1> <field3>test2</field3> </node> 尝试此操作时，我收到未指定的错误（因为我正在使用免费的在线工具进行转换）。 //text()='/' 不是有效的位置路径。 在任何情况下，您想要删除元素，而不是文本节点 - 所以您应该使用类似的东西： <xsl:template match="*[.='/']" />
我运行了 nvm ls-remote ，列表的末尾如下所示： v14.17.6（LTS：镄） v14.18.0（LTS：镄） v14.18.1（LTS：镄） v14.18.2（LTS：镄） ...
我需要帮助更新 Mac 上的 Node 版本才能使用 Next JS，即使已安装，我仍然收到错误消息
我正在创建一个新的 NextJS 应用程序，它说它需要较新版本的 Node >= v18.17.0 才能与 Next JS 一起使用。我一直在尝试更新，但它说活动节点版本是
自动完成功能不适用于 VSCode 中的 TypeScript + Node
所以如果我编写纯 JS (.js)，它的工作方式如下： 但对于 TypeScript (.ts) 它不起作用：
我正在安装这些 npm 软件包： npm 我表达 body-parser bcrypt cors dotenv gridfs-stream multer multer-gridfs-storage 头盔 morgan jsonwebtoken mongoose 但是，当...
假设最初我们有一个包含 3 个分区的主题和一个包含 3 个消费者的消费者组，从该主题进行消费。如果我们在消费者组中再添加一个消费者，分区会重新平衡吗
在 ec2 中安装节点，Amazon Linux2 错误 glibc >= 2.28
尝试在以下位置安装 npm 和 node： 猫 /etc/os-release 名称=“亚马逊Linux” 版本=“2” ID=“amzn” ID_LIKE="centos rhel fedora" 版本_ID=“2” 漂亮...
所以客户端javascript中的异步编程是setTimeOut在浏览器API中运行，因此它不会阻塞javascript单线程。由于我们在 Node 中没有浏览器 API，谁...
我很确定我的ID和秘密是正确的。 这是真正的链接：（https://sandbox.mngkargo.com.tr/en/node/266） 发布 https://testapi.mngkargo.com.tr/mngapi/api/token 标题： 内容-
我定义了一个 Node 类，其值类型带有模板 模板 类节点{ T 值； 民众： 节点 (T & v) : val (v) {} ... 无效打印（）{cout<< v <<...
Typescript 无法与 tsconfig.json 一起使用
在项目中使用 tsconfig 运行 tsc --watch 时，出现以下错误。 它需要 Node js 中的 React 和 Redux 类型。 错误 TS2688：找不到“abstract-leveldow...”的类型定义文件...
我正在使用passport-google-oauth 运行node.js。从我的 package.json 中： "passport-google-oauth": "~1.0.0", 我遵循了本教程：https://scotch.io/tutorials/easy-node-authentication-google 在...
我已将 auth0 集成到 remix.run 应用程序中，现在尝试保存登录时发出的访问令牌： 从“@remix-run/node”导入{createCookieSessionStorage}； 导入 { getOrThrow ...