腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Zio-Kafka
:
向
主题
生成
消息
、
、
我正在尝试使用0.15.0版本的库
zio-kafka
向
Kafka
主题
生成
一些
消息
。 显然,我对ZIO生态系统的理解是次优的,因为我不能产生一个简单的
消息
。
浏览 15
提问于2021-08-07
得票数 0
回答已采纳
1
回答
卡夫卡消费者无法获得先前未消费的事件
、
、
步骤1:只使用一个分区创建
主题
:步骤2:
向
主题
test
生成
一些
消息
。步骤3:开始使用
主题
test。它可以获取步骤2中推送的所有
消息
。但是,当我尝试在两个分区中使用
主题
时,使用者
浏览 1
提问于2018-05-25
得票数 0
1
回答
如何更新Kafka/Kafka流中的数据?
、
假设有Kafka
主题
顺序。因为我知道Kafka
主题
是不可变的,并且我不能改变
消息
JSON,所以只需要创建一个新的具有Chnaged值的
消息
,对吗?
浏览 41
提问于2020-07-05
得票数 0
回答已采纳
1
回答
如何从同一个生产者
向
不同的Kafka
主题
和模式注册中心
生成
消息
、
、
、
我正在尝试在我的Java应用程序中从相同的生产者
向
不同的kafka
主题
生成
消息
。 这就是我创建我的生产者并向
主题
发送
消息
的方式。producer.send(topic1, genericRecord, datasetId1); producer.send(topic2, genericRecord, datasetId2); 然而,这两个不同的
主题
具有不同的发送到topic2的
消息
生成
正确,但发送到topic1的
消息
浏览 46
提问于2021-10-28
得票数 0
3
回答
如何使用Kafka流DSL函数处理重复
消息
我的要求是使用kafka流DSL跳过或避免从输入
主题
接收的重复
消息
(具有相同的密钥)。源系统->输入
主题
-> Kafka流->输出
主题
目前,我正在使用flatMap来
生成
多个有效负载密钥,但是flatMap是无状态的,因此在接收到输入
主题
时无法避免重复的
消息
处理。我正在寻找DSL,它可以跳过从输入
主题
接收到的重复记录,并
浏览 1
提问于2019-04-23
得票数 1
回答已采纳
2
回答
发送SQS
消息
时调用Lambda
、
、
、
我希望每次发送SQS
消息
时都调用lambda。
浏览 2
提问于2017-09-14
得票数 1
回答已采纳
1
回答
卡夫卡流是否适合触发记录的批处理?
、
、
、
、
上下文 我已经设置了三个服务,每个服务都
生成
一个特定的JSON有效负载(,需要不同的时间来完成),这是处理一个
消息
所必需的,该
消息
是将所有三个JSON有效负载组合到一个单一有效负载中的结果。信息聚合器必须使用来自三个服务的
消息
(它们在非常不同的时间发送到各自的Kafka
主题
,例如服务1需要半小时来响应,服务2和3需要不到10分钟),以便
生成
一个最终的有效载荷(表示为聚合信息)发送到另一个Kafka3条
消息
来
生成
最终
消息
,并将最后<em
浏览 3
提问于2021-12-20
得票数 2
回答已采纳
1
回答
如何设置弹性节点APM分布式跟踪,以配合Kafka和多节点服务?
、
、
我使用Kafka作为队列,节点服务使用Kafka-Node
生成
和消费发送到Kafka
主题
的
消息
。 我一直在使用自制的分布式跟踪解决方案,但现在我们将转向Elastic APM。我希望能够像下面这样跟踪事务:服务A
向
服务B发送HTTP请求,服务B
向
Kafka
主题
C
生成
HTTP请求,服务D从Kafka
主题
C消费该请求,服务D将一些数据放入Kafka
主题
E,服务B从Kafka
主题
E
浏览 28
提问于2019-04-01
得票数 5
回答已采纳
1
回答
通过控制台在远程服务器上测试Kafka broker/topics的最简单方法是什么?
、
、
此应用程序负责
向
托管在A机器上的代理中的
主题
生成
消息
。但它不能
向
主题
生成
任何
消息
,这就是我想通过控制台进行测试的原因。我不想在B机器上安装太多的应用程序。
浏览 23
提问于2021-03-24
得票数 0
回答已采纳
1
回答
通过REST
向
firebase中的用户组发送通知
、
、
我试图发送用户列表的通知,这是否适用于firebase。我尝试并成功地发送了一个特定用户的通知和广播通知,但是我没有为一组用户找到一个示例请求!URL:正文:{ "detail": "I am firebase notification. you can customise me. enjoy" "
浏览 0
提问于2020-08-29
得票数 0
回答已采纳
2
回答
使用topic启用ACL的Kafka java生产者和消费者
、
、
、
有各种使用命令行
生成
/消费
消息
的示例。我们是否需要任何额外的配置来使用JAVA api
向
/从安全的kafka
主题
生成
/消费
消息
。
浏览 2
提问于2016-06-15
得票数 0
1
回答
未清除Kafka
消息
、
、
我正在做一些关于如何清除kafka
主题
中的
消息
的实验。我发现,如果我们将
主题
的"retention.ms“属性设置为某个较短的时间值,比如1秒,那么根据我的理解,1秒后该
主题
中的
消息
将被清除。我运行了一个
生成
器,它
向
topic
生成
了很少的
消息
,并在一段时间后停止了它。同时,我运行了一个控制台使用者,这样它就可以获得
生成
的
消息
。在保留时间过后,我为同一
主题
启动了另一个消费者
浏览 17
提问于2019-06-13
得票数 1
回答已采纳
2
回答
无法使用kafka-node
向
kafka生产者发送
消息
、
、
我正在尝试创建一个简单的NodeJS应用程序,它将发送
消息
到生产者并使用它们。 下面是NodeJS代码。
浏览 14
提问于2021-09-14
得票数 0
1
回答
我如何存档卡夫卡的信息?
、
如果我们想要向某个
主题
发送特定的
消息
,那么我们如何将Kafka
消息
存档,然后发送到该
主题
或其他
主题
? 我们可以根据特定的偏移量重放吗?
浏览 5
提问于2018-07-05
得票数 0
3
回答
将Kafka Consumer和Producer集成在一个函数中
、
、
、
、
我们需要开发一个代码,在这个代码中,消费者监听特定的kafka生产者,然后在相同的函数中从当前消费的数据中产生一个经过处理的数据到不同的生产者
主题
。这是为了将代码与Java集成在一起,在Java中,Java
向
一个
主题
生成
一条
消息
,flink使用该
消息
,并向另一个
主题
生成
新数据,以便Java进一步处理。 请让我们知道是否有其他方法来完成这一过程。
浏览 0
提问于2018-01-29
得票数 3
1
回答
为什么kafka流要重新处理代理重新启动后产生的
消息
?
、
、
我创建了两个
主题
(topic1和topic2)。Produced on topic1 - processed message - write to topic2我只发了一条信息。现在,在没有停止代理的情况下,我
向
topic1
生成
了
消息
,并等待streams应用程序在再次
生成
之前将其写入topic2。 Streams应用程序表现得很奇怪。有时一条产生的
消息
有2条
浏览 0
提问于2018-06-07
得票数 2
2
回答
RabbitMQ -
主题
交换和竞争消费者
、
、
我成功地设置了一个
主题
交换( Topic ),并且能够同时
向
多个消费者传递
消息
。 甚至可以进行
主题
交换吗? 谢谢
浏览 4
提问于2016-09-16
得票数 2
回答已采纳
2
回答
如何避免Apache Pulsar中不活动
主题
的自动删除
、
我有一个应用程序,该应用程序在特定
主题
下
向
Pulsar
生成
消息
,并在该应用程序完成后关闭该应用程序;同时,不存在用于读取该
主题
的使用者。过了一段时间,当我创建一个使用者并想要读取写入的数据时,我发现所有的数据都丢失了,因为我编写的
主题
被Pulsar删除了。 如何在Pulsar中禁用非活动
主题
的自动删除?
浏览 0
提问于2019-07-24
得票数 4
回答已采纳
2
回答
与Jenkins分支机构的问题
、
、
、
当Branch Specifier : */devTo请求从dev
生成
到stage分支时,在dev分支上运行测试,当从stage
生成
拉请求到主分支时,在舞台分支上运行测试有人能帮我解决这个问题吗?
浏览 2
提问于2019-12-24
得票数 1
1
回答
通过一个连接发送和使用
消息
我的案例:有连接"A“、"B”和"C",它们以“
主题
1”的名称订阅
主题
。"A“
向
主题
发送信息,但它没有收到它。"B“和"C”接收此
消息
。如果"C“
向
主题
发送
消息
,那么得到
消息
的是"A”和"B“。
浏览 2
提问于2020-05-29
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
单Broker集群,RocketMQ宕机时消费失败会有什么问题
谷歌将在开发者大会上发布PaLM 2
“事件驱动架构”Kafka中的模式注册表和模式演化
用户需求推动AI应用加速繁荣 办公场景有望率先落地
Kafka权威指南(二):为什么选择Kafka
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券