程序员经验分享-hwhale

通过API服务端点消费来自Kafka主题的消息

2024-04-17

目前，我有一个 API 服务端点（用 .netcore6 C# 编写），它将接受消息对象并将其保存到数据库，然后将该消息发布到 kafka topic-2。

如何利用我的 API 服务端点始终监听/观看并连接到 kafka topic-1，一旦新消息出现在 kafka topic-1 中，然后查找新消息，然后一一消费这些消息并将消息传递到 API 服务端点？


为此，您将使用 Kafka 消费者，而不是“API 端点”。

https://github.com/confluenceinc/confluence-kafka-dotnet https://github.com/confluentinc/confluent-kafka-dotnet

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

c

ApacheKafka

eventhandling

kafkaconsumerapi

EventListener

通过API服务端点消费来自Kafka主题的消息 的相关文章

  • SetWindowsHookEx 函数返回 NULL

    我正在研究 DLL 注入 但收到错误如下 挂接进程失败 87 参数不正确 目标进程和dll都是64位的 注入代码为 BOOL HookInjection TCHAR target TCHAR dll name https msdn micr

  • WebClient读取错误页面的内容

    我有一个加载页面内容的应用程序 我使用 WebClient 类 即使服务器返回 404 500 等错误 我也需要检索内容 我需要这样的东西 WebClient wc new WebClient string pageContent try

  • 使用不带参数的 Split() 时，默认分隔符是什么？

    所以我看了看String Split 今天 C 中的方法 我意识到你也可以向它传递零参数 这是我从未考虑过的 使用时默认的分隔符是什么Split 没有任何参数 如果没有值 则为空白 来源自here https msdn microsoft

  • 为什么派生类不使用基类的operator=（赋值运算符）？

    以下是实际问题的简化版本 而不是打电话Base operator int 代码似乎生成了一个临时的Derived对象并复制它 既然函数签名似乎完美匹配 为什么不使用基本赋值运算符 这个简化的示例没有显示任何不良影响 但原始代码在析构函数中有

  • 通过单个 GPIO 引脚转储闪存

    我正在使用 Infineon 的 XMC4500 Relax Kit 并尝试通过单个 GPIO 引脚提取固件 我非常天真的想法是通过 GPIO 引脚一次转储一位 然后用逻辑分析仪以某种方式 嗅探 数据 伪代码 while word by w

  • 如何使用汇编获取BIOS时间？

    我正在从头开始实现一个小型操作系统 用于教育目的 现在 我想使用汇编来获取 BIOS 时间 我对此进行了很多搜索 但找不到任何代码示例来执行此操作 如果有人可以提供任何参考或代码示例或与此相关的任何内容 我将非常感激 See 时钟中断 1a

  • 如何在 Windows 窗体中运行屏幕保护程序作为其背景？

    如何在 Windows 窗体中运行屏幕保护程序作为其背景 用户还可以在屏幕保护程序运行时与表单控件进行交互 为什么这个 我们有一个案例 需要在用户时运行 Windows Bubbles 屏幕保护程序 可以继续与表单控件交互吗 您可以使用以下

  • .net Framework (.net 4.0) 中定义 Base 3 数字的类

    我正在寻找一些可以用来定义 3 基数 三进制数 的类 有什么我可以在 net 框架中使用的东西或者我需要写一些东西吗 谢谢你的帮助 您可以使用解析Convert ToInt32 s base http msdn microsoft com

  • 如何使用泛型类型的 DataContractSerializer 编写自定义序列化器？

    我想编写一个自定义序列化器 用于将会话状态存储到Azure 缓存 预览版 这意味着这个自定义序列化器必须实现IDataCacheObjectSerializer 如果我错了 请告诉我 我需要编写这个自定义序列化程序的原因是我需要序列化一些包

  • 为什么重载方法在 ref 仅符合 CLS 方面有所不同

    公共语言规范对方法重载非常严格 仅允许根据其参数的数量和类型来重载方法 如果是泛型方法 则根据其泛型参数的数量进行重载 根据 csc 为什么此代码符合 CLS 无 CS3006 警告 using System assembly CLSCom

  • 不要声明只读可变引用类型 - 为什么不呢？

    我一直在阅读这个问题 https stackoverflow com questions 2274412 immutable readonly reference types fxcop violation do not declare r

  • C# 中处理 SQL 死锁的模式？

    我正在用 C 编写一个访问 SQL Server 2005 数据库的应用程序 该应用程序是数据库密集型的 即使我尝试优化所有访问 设置适当的索引等 我预计迟早会遇到死锁 我知道为什么会发生数据库死锁 但我怀疑我能否在某个时候发布不发生死锁的

  • 如何将字符串转换为 Indian Money 格式？

    我正在尝试将字符串转换为印度货币格式 例如如果输入为 1234567 则输出应为 12 34 567 我编写了以下代码 但它没有给出预期的输出 CultureInfo hindi new CultureInfo hi IN string t

  • asp.net c# 防止在从服务器端代码更改索引时触发 selectedindexchanged 事件

    我在同一个 aspx 页面上有两个下拉列表控件

  • 在 .NET 中记录 StackOverflowException

    最近 我的 NET 应用程序 asp net 网站 中出现了堆栈溢出异常 我之所以知道该异常是因为它出现在我的 EventLog 中 我知道 StackOverflow 异常无法被捕获或处理 但是有没有办法在它杀死您的应用程序之前记录它 我

  • Dynamics Crm：获取状态代码/状态代码映射的元数据

    在 Dynamics CRM 2011 中 在事件实体上 状态原因 选项集 也称为状态代码 与 状态 选项集 也称为状态代码 相关 例如看这个截图 当我使用 API 检索状态原因选项集时 如下所示 RetrieveAttributeRequ

  • 如何将 CSV 文件读入 .NET 数据表

    如何将 CSV 文件加载到System Data DataTable 根据CSV文件创建数据表 常规 ADO net 功能是否允许这样做 我一直在使用OleDb提供者 但是 如果您正在读取具有数值的行 但希望将它们视为文本 则会出现问题 但

  • 如何强制执行特定的 UserControl 设计

    我正在编写一个基本用户控件 它将由一堆其他用户控件继承 我需要对所有这些后代控件强制执行某种设计 例如 顶部必须有几个按钮以及一个或两个标签 后代用户控件区域的其余部分可以自由放置任何内容 最初 我认为我可以将一个面板放到 Base Use

  • 程序退出后，TcpListener Socket 仍处于活动状态

    当我的程序退出时 我试图停止 TCP 侦听器 我不关心套接字或任何活动客户端套接字上当前活动的任何数据 套接字清理代码本质上是 try myServer Server Shutdown SocketShutdown Both catch E

  • 如何确定给定方法可以抛出哪些异常？

    我的问题和这个真的一样 找出 C 中方法可能抛出的异常 https stackoverflow com questions 264747 finding out what exceptions a method might throw in

随机推荐

  • 检查类模板是否已实例化？

    有没有一种简单的方法可以查看一个类是否已在翻译单元中实例化 C Primer 中的一个练习询问每个带标签的语句 是否发生实例化 template

  • 简单注入器从命名空间注册所有服务

    我的服务接口的命名空间为Services Interfaces 服务接口的实现有一个命名空间Web UI Services 例如 我有 2 个服务实现 IUserService 需要注册到UserService ICountryServic

  • Delphi：如果我在项目中使用包，为什么“使用调试 DCU”会变得无效？

    我正在构建一个使用 JVCL 插件系统的项目 该系统依赖于运行时 Delphi 包 自从我将它添加到我的项目中后 调试就变成了一场噩梦 因为我不再能够单步跟踪源代码任何 VCL 或 RTL 单元 它们在调试器中都被标记为灰点 当相关函数出现

  • JavaScript 事件时间戳不一致

    我注意到 当我单击站点上的一个元素时 Firebug 在事件处理程序中将 e timeStamp 报告为 9 位数字 例如 866523917 而当我单击另一元素时 Firebug 在该处理程序中将 e timeStamp 报告为一个 16

  • WPF查找控件

    我在 WPF 页面上用过程代码创建了一个网格 现在我想引用该网格 Grid grid Grid This FindName myGridName 不起作用 有想法吗 当您在代码中创建元素时 还需要调用 RegisterName 方法以允许

  • 使用 jQuery AJAX 从 Laravel 5 中的联系表单发送电子邮件

    我在 Laravel Blade 中有联系表 div ul foreach errors gt all as error li error li endforeach ul Form open array route gt contact

  • Python有字符串“包含”子字符串的方法吗？

    这个问题的答案是社区努力 help privileges edit community wiki 编辑现有答案以改进这篇文章 目前不接受新的答案或互动 我正在寻找一个string contains or string indexofPyth

  • 如何使用 API 创建 GitHub Gist？

    通过查看 GitHub Gist API 我了解到可以为匿名用户创建 Gist 而无需任何 API 密钥 身份验证 是这样吗 我找不到以下问题的答案 创建时是否有任何限制 要点数量 等 有没有任何示例可以让我从表单文本输入字段发布代码来创建

  • pandas.to_datetime 时间字符串格式不一致

    我正在尝试转换 a 的索引pandas DataFrame从字符串格式到日期时间索引 使用pandas to datetime 导入熊猫 In 1 import pandas as pd In 2 pd version Out 2 0 10

  • size_t 是字长吗？

    Is size t编译代码的机器的字长 用 g 解析 我的编译器视图size t as an long unsigned int 编译器内部是否选择大小size t or is size t实际上是在某些预处理器宏中的 typedefstd

  • 如何解析此 Flickr 响应？

    我从 Flickr 的 api 站点中的示例响应中得到了这一点 jsonFlickrApi method content flickr test echo format content json api key content 8038f7

  • Play框架2.0.1不断尝试演化出错误的数据库类型

    我正在开发部署在 openshift DIY 应用程序上的 play 2 0 1 应用程序 我在数据库方面遇到了麻烦 因为游戏一直试图发展错误的数据库 我有一个 mysql 数据库 并且 play 创建一个 H2 数据库演化脚本 这是脚本

  • 将 uri 保存到共享首选项并使用媒体播放器播放

    这是我用来将 Uri 的字符串表示形式保存到 SharedPreferences 的代码 public void onActivityResult int requestCode int resultCode Intent data sup

  • Java 8 中使用了哪个 JAXB 版本？

    JAXB Java Architecture for XML Binding 已作为 Maven 工件发布 尽管它在 Java 8 以及具有选项的 Java 9 10 之前与 JRE 捆绑在一起 我的问题是 Maven Central 上的

  • 计算时间长

    这是我上一个问题的链接 它引导我找到了这个问题 C 嵌套 foreach 循环优化 https stackoverflow com questions 7729231 c nested foreach loop optimization 计

  • 为什么服务器控件在放置在内容标记内时会带有下划线？

    我有一个网络内容表单 其中包含Div以及各种服务器控件 例如DropDownList 当我运行该应用程序时 它运行良好 没有任何错误 但当我查看 HTML 源代码时 服务器控件带有红色下划线 将鼠标移过来时 说 DropDownList 会

  • Visual C# 2010 Express：为新类指定默认访问修饰符？

    每当我使用 Visual Studio 2010 Express C 创建新类时 它都会创建不带访问修饰符的新类 十分之九我希望我的新课程公开 如何让 Visual Studio 默认创建带有 public 修饰符的空类模板 诀窍是创建一个

  • 删除 numpy 数组的重复行[重复]

    这个问题在这里已经有答案了 如何删除二维的重复行numpy array data np array 1 8 3 3 4 1 8 9 9 4 1 8 3 3 4 答案应该如下 ans array 1 8 3 3 4 1 8 9 9 4 如果有

  • HSQLDB服务器模式用户名/密码

    如果我使用 Java 代码在服务器模式下启动 HSQLDB 则服务器启动不会出现任何问题 但是 当我尝试通过 Java 代码或通过 HSQLDB DatabaseManagerSwing 连接到相同的数据库时 我无法连接 我在仅内存模式下使

  • 通过API服务端点消费来自Kafka主题的消息

    目前 我有一个 API 服务端点 用 netcore6 C 编写 它将接受消息对象并将其保存到数据库 然后将该消息发布到 kafka topic 2 如何利用我的 API 服务端点始终监听 观看并连接到 kafka topic 1 一旦新消

热门标签