我正在尝试使用“camel-azure-storage-datalake-kafka-connector”从 Kafka 连接到 Azure ADLS Gen2 我有一个运行 Docker 的 Linux 机器，其中包含 debezium/zookeeper、debezium/kafka 和 debe...
我是 Kafka 和设置 Kafka UI 的新手，尽管我在最后的 docker 和 docker-compose 上设置了先决条件。 我最后有一个 3 节点 Kafka 集群设置。 下面是 docker-compose...
如何在 Kubernetes multipod 部署中使用 spring kafka 处理 Kafka 容器生命周期
我正在使用 Spring kafka 实现，我需要通过 REST API 启动和停止我的 kafka 消费者。为此，我正在使用 KafkaListenerEndpointRegistry endpointRegistry 端点注册表。
Maui dotnet 8 可与 dotnet build 配合使用 - 不在 Visual Studio for mac 17.6.7 内
我有一个毛伊岛解决方案，我从 dotnet 7 升级到 dotnet 8，它在 Visual Studio for mac 17.6.7 的 dotnet 命令行上失败，它构建得很好。我可以这样做吗？在 moc 视觉研究中构建...
Kafka Java Consumer Client 是单线程的吗
我们正在开始使用 Kafka， 在阅读本文时 - https://docs.confluence.io/kafka-clients/java/current/overview.html - 它似乎暗示客户端是单线程的。 * 由于这个...
如何使用 kafka msg key 作为 s3 连接器中的分区标准或 我怎样才能获得密钥并将其存储在 s3 对象中 谢谢！
我正在尝试将元数据添加到 kafka 的输出到 S3 存储桶中。 目前，输出只是来自 kafka 主题的消息的值。 我想用下面的东西把它包起来......
dotnet 工具安装在 sdk:8.0.100-bookworm-slim 中挂起
我正在将应用程序从 NET6 迁移到 NET8。该应用程序是在 dockerfile 中构建的。为了进行代码分析，dotnet 工具“dotnet-sonarscanner”安装在构建映像中。 在N...
即使部署在 kubernetes pod 上，kafka 主题仍然是不可变的吗？
我在 kubernetes pod 上部署了 kafka 主题和模式注册表，我尝试修改/更改 kafka 主题和模式注册表的清单文件，然后模式注册表的行为在
我创建了一个只有一个分区且在本地主机上没有复制的 kafka 主题，通过 kafka 控制台消费者和控制台生产者测试了消息传输，它工作正常，但在 tr...
使用 kafka-go 和循环平衡器时，数据始终进入分区 0
我正在使用 kafka-go 库将消息写入 Kafka。我正在使用循环平衡器，但数据始终进入分区 0。我尝试忽略所有消息的分区字段，但是...
我如何在本地运行假kafka主题（内存中）来测试kafka？
我尝试了一些依赖项，它期望安装docker或抛出运行时异常 我想在没有 Docker 设置的情况下在指定端口本地运行一个假 Kafka。 还有我的申请...
我想从Kafka获取数据，此方法成功获取记录但无法传递给变量。这是我的代码 公共无效 subscribeFromKafka() 抛出异常 { 列表结果=新
作为 dotnet 集合 Stack.cs 源代码 公共 T Peek() { int 大小 = _size - 1; T[] 数组 = _array; if ((uint)size >= (uint)array.Length) { ThrowForEmptyStack(); ...
在我的 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...
我使用 Visual Studio 创建了一个 ASP.NET Core Web API 项目并添加了我自己的 Dockerfile： 来自 mcr.microsoft.com/dotnet/sdk:8.0 AS 构建 工作目录/应用程序 复制 *.csproj ./ 运行 dotnet 恢复 复制 。 ....
有没有办法将AWS Cloudwatch日志输入Kafka主题
我正在努力寻找这方面的任何方向。我有一个内部系统可以处理日志以进行监控。我希望从 Cloudwatch 发送错误并在 kafka 主题上发布，其中...
我正在寻找一种从 Kafka 主题中删除（完全删除）已使用记录的方法。我知道有几种方法可以做到这一点，通过更改主题的保留时间或删除...
从 kafka 连接 API 获取任务 ID 以在日志中打印
我有一个kafka连接接收器代码，下面的json作为curl命令传递来注册任务。 如果有人知道如何获取我的连接的任务 ID，请告诉我。例如在
我们正在尝试在我们的项目中使用 kafka 流来从一个主题读取数据并写入另一个主题，并且我们有一个使用 KafkaHeaders 作为过滤某些记录的机制的用例。 例如，...
将 dotnet core (.NET Core) 嵌入到 Windows/Linux 上的本机应用程序中
是否有可能将 dotnet core (.NET Core) 环境嵌入到本机进程中？ 我的用例是现有的游戏服务器，我想在其中提供扩展游戏的可能性...
ASP.Net Core 容器在自定义端口 8080 上运行，但 ASP.Net 容器在 Docker Windows 中在固定端口 80 上运行
我根据以下图片制作了两个容器： ASP.NET核心 mcr.microsoft.com/dotnet/aspnet:8.0.0-windowsservercore-ltsc2019 网络应用程序 来自 mcr.microsoft.com/dotnet/framework/aspnet:4.8-windowsserv...
我有两个具有相同组ID的消费者服务器订阅了相同的主题。 一台 kafka 服务器仅运行一个分区。 据我所知，消息应该在这两个中随机消耗
具有手动偏移提交功能的 Kafka 消费者客户端一次只允许客户端
我目前正在使用一个Java Kafka消费者，它手动提交偏移量（enable.auto.commit = false），我发现即使我生成了多个实例，我发现这样的设置也是如此
如何仅删除已消费的消息以及如何在kafka主题中显示未消费的消息？
我们将一个项目从ActiveMQ迁移到Kafka。 过去我们向很多队列写入了太多的消息，消费完之后，ActiveMQ会自动删除消费的消息。仅未消耗
我有一个 dotnet 应用程序，可以将日志推送到酒店收集器。在本地，使用 docker compose 一切正常，但是当我尝试在 kubernetes 中运行相同的内容时，我只得到跟踪，但没有日志。 在
Azure Pipelines 托管代理已更新，现在包含 .Net 5.x SDK/运行时以及较旧的 .Net Core
最近将我的应用程序升级到.NET 8.0。 Azure 管道中出现以下错误。 ##[错误]错误：进程“/opt/hostedtoolcache/dotnet/dotnet”失败，退出代码为 2 信息：Azure Pipelines h...
Azure 函数（dotnet-isolated）无法启动，并出现 Grpc.Core.RpcException：StatusCode="Unavailable" - Mac M1
我最近得到了一台Mac M1，并且正在设置我的机器以进行Azure Function（dotnet-isolated）开发。 我按照下面的文档进行操作，该文档在我的 Windows 10 计算机上运行得非常好。
在结构化流 API 中跨多个集群使用共享 Kafka 主题执行 Spark 作业
我正在开发一个 Spark 项目，我需要在两个不同的集群上运行作业，两个集群都使用相同的 Kafka 主题。我希望这些作业能够有效地共享负载并平衡
运行 dotnet ef migrations add XYZ 将导致在项目中创建 Migrations 目录。该目录是否应该提交版本控制（Git 等）？
dotnet core中的[ScriptIgnore]在哪里？
我正在将一个大型存储库转换为.net core，但我无法找到以前位于 System.Web.Script.Serialization 内部的 [ScriptIgnore] 属性的替代品。 有没有替代品...
我有一个 dotnet core 6 函数，包含以下几行 var csv = new CsvReader(阅读器, 配置)) var 记录 = csv.GetRecords().ToList(); 我设置模拟来模拟某些对象......
Python KafkaTimeoutError：等待未来超时
我正在使用 Kafka 将日志发送到主题。发送消息时，我总是收到此错误 消息：“测试日志” 参数：() --- 记录错误 --- 回溯（最近一次调用最后一次）： 文件“...
我们使用 .NET 客户端进行 GRPC：https://github.com/grpc/grpc-dotnet 我们使用 DuplexStream 因为许多消息可以来自客户端首先初始化的同一个通道。 我们如何
Apache Spark Structured Streaming 中 Spark UI 上的查询和阶段卡住了
我在 EMR 集群 (6.14) 上使用 Apache Spark Structured Streaming (3.1.2)。 Spark 结构化流将数据从 Apache Kafka 流式传输到 Delta Lake 表。当我打开 Spark UI 时，我看到以下内容
maui android 应用程序在管道中构建失败，并出现错误“找不到 Android SDK 目录”
如果没有任何代码更改，Android 的管道构建将失败并出现以下错误。 /opt/hostedtoolcache/dotnet/packs/Microsoft.Android.Sdk.Linux/33.0.95/tools/Xamarin.Android.Tooling.targets(70...
我有一个使用 GDAL 和 GDAL.Native 包的 .NET Core C# Web 项目。一切在本地运行良好，但在发布到 Debian 服务器后，它会报告一堆消息，例如 /usr/share/dotnet/s...
debezium 日期/时间字段值超出范围：0000-12-30T00:00:00Z
我们使用 Debezium 将数据同步到 在源表中我们有列timestamptz start_at，当值为0时start_at='0001-01-01 00:00:00.000000 +00:00'，但是当我们检查kafka中的数据时，它是
如何使用 .NET TEST EXPLORER 在 VS Code 中运行 NUnit 测试
我想从 .NET TEST EXPLORER 运行单元测试，而不是命令行。我可以在导航到单元测试目录并执行 dotnet test 时运行测试。 但选择 .NET TEST EXPLORER...
如何使用 C# 开发套件在 Visual Studio Code 中设置 dotnet Release 配置构建？
我已经安装了 Visual Studio Code 和“C# Dev Kit”。看起来没有默认的方式让人们选择发布配置构建。 查看文档包，它提到了 a...
Azure Function App 无法启动 Docker 容器，原因是“Azure.RequestFailedException：指定的资源名称包含无效字符。”
我们有一个从 Docker 映像部署的 Azure Function 应用程序。 该函数正在运行 .NET 8.0，FUNCTIONS_EXTENSION_VERSION = ~4 且 FUNCTIONS_WORKER_RUNTIME = dotnet-isolated。 该应用程序包含...
Groovy 抛出 可能的解决方案：解析 LinkedHashMap 时出现 parseText(java.lang.String) 错误
我正在尝试检查kafka输出消息中是否存在该密钥，如果存在则进行进一步的操作。 卡夫卡主题的输出消息如下 [“随机名称_547hcg”：{ “访问_...
我有一个使用 AWS 上的 MSK 集群的 kafkaStreams 应用程序。 我需要清理状态存储（在我的应用程序中使用一些 KTable 后创建）。 我找不到任何方法来访问文件系统......
发往 Azure 服务总线的消息会产生成功的请求，但队列中没有消息
我正在尝试在 DotNet 中实现后台服务，将消息发送到 Azure 服务总线中的队列。我的代码如下所示： 公共类 AuditBackgroundService ：BackgroundService，
自消息发布或 sinse 服务器启动以来，kafka 是否计数 log.retatantion
如果我将 log.retantion 设置为 24 小时，则在 1.1.24 15:30 发布了一条消息。 然后服务器宕机了25小时，24年1月16日16:30再次启动，消息会立即删除吗...
如何在expo react-native-app中收到FCM通知时禁用声音
我正在使用 firebase admin 从 dotnet 服务器发送通知来反应本机应用程序。在任何情况下一切都工作正常（前景、背景、死亡），但我希望用户能够
dotnet 工具在 Linux 中无法工作。您必须安装或更新 .NET 才能运行此应用程序。应用程序
这是我在电脑上安装的.NET 的信息。 点网--信息 .NET SDK： 版本：8.0.100 提交：57efcf1350 工作负载版本：8.0.100-manifests.6c33ef20 运行时环境...
使用 ASP.NET Core 和 TailwindCSS 进行热重载（或者：向 dotnet watch 添加额外的命令）
我正在研究将 TailwindCSS 与 ASP.NET 结合使用的良好热重载工作流程。 我决定使用 VSCode，因为 VisualStudio 没有良好的顺风扩展，而 Rider 的扩展也不支持...