假设我有一个主题"test“，它已经有了一堆消息，现在我想订阅这个主题。但我不想在新订阅之前使用所有发布的消息。基本上，我只想消费订阅后发布的最新消息。
浏览 12提问于2021-06-03得票数 0
在消费卡夫卡主题时，卡夫卡将把所有信息按顺序传递给消费者。现在假设一个主题中的数据是实时数据，其中只有针对每个关键事项的最新消息，即相同密钥的所有先前消息都可以被认为是过时的(例如股票价格)。当处理速度低于生产速度时，是否有一种优雅的方法可以忽略所有以前的密钥消息，而只处理最新的消息<
浏览 3提问于2022-08-31得票数 0
如何通过忽略topic中的所有已有消息，只消费kafka topic的最新消息。我有两个相同主题的消费者，当我开始使用来自该主题的消息时，它会获取最旧的消息。我需要在我的消费者启动后消费消息。我在我的消费者配置中尝试了这个配置，但这不起作用。
浏览 26提问于2021-07-09得票数 0
2回答
匹配传入和传出电话号码
、、、
我目前正在制作一个短信查看应用程序，并使用ContentResolver来获取手机上的所有短信(是的，我知道其中的风险)。像其他应用程序一样，我希望将来自同一个人的所有消息分组到一个线程中，显示来自他们的最新消息，并按最后一条消息的日期对联系人进行排序。当涉及到传入消息的地址值时，它们都包含国家代码(例如+44
浏览 0提问于2011-01-26得票数 0
回答已采纳
1回答
我有一个卡夫卡主题的制作人，它一直在向卡夫卡主题推送一些信息。此外，我还有另一个服务在阅读来自主题的这些消息。我有一个业务用例，有时使用者需要忽略队列中已经存在的所有消息，并且只开始处理新的即将出现的消息。可以在不停止和重新启动kafka服务器的情况下对其进行归档。
我正在忙着走。因此，如果kafka支持这样<
浏览 9提问于2022-09-15得票数 0
mqtt社区会考虑将消息信息放在主题名称中作为反模式吗？
我有一个客户端，它有一个围绕着rabbitmq的庞大库，我正在尝试修改他们的客户端和服务器代码，让他们能够为蚊虫配置他们的服务。他们的一个核心需求是TTL，客户端有时可以在服务器恢复联机之前坐着发布数据，他们不希望TTL之外的消息出现。他们的消息信封系统是一个精心设计的json，1)包装或更改这个json将是痛苦的<
浏览 2提问于2020-10-21得票数 1
回答已采纳
1回答
我在python中有一个需要服务器向设备发送mqtt消息的项目代码，它需要解决设备和云服务器应用程序操作和信息同步的问题。我发现！的客户端函数有一个参数Client(client_id="", clean_session=True)来恢复未连接的订阅，以接收脱机期间发送的消息。但我在实验中发现，断开连接的时间越长，恢复的时间就越长，消息的恢复速度也就越慢。
如果你们能给我一些关于
浏览 0提问于2019-08-02得票数 2
1回答
我们正在使用AWS IoT。但是有一种可能性，设备可以发布消息到任何其他主题。我想要计算由这些独立的设备发布到所有主题的消息的数量，并实现节流。
我尝试使用通配符主题名( +/*或
浏览 7提问于2019-11-08得票数 0
回答已采纳
我有一个简单的python函数，在这里，我只需要从公共主题中获取输入，然后打印出来。json.loads(pubsub_message) for k,v in i.items():如果我使用了callback(message):如何将消息转换为
浏览 2提问于2020-09-23得票数 2
回答已采纳
我在教义手册中找不到如何做一个非常简单的查询。我不知道如何管理SQL的等价物"JOIN ...“和MongoDb在一起。* @MongoDB\ReferenceMany(targetDocument="Message") protected $messages;我有一个用户id和一个主题我想要：2)查找用户关于该主题的最新消息
$dm-
浏览 1提问于2013-03-03得票数 1
回答已采纳
假设我有一个publisher应用程序，它运行并发布了20条消息，然后就关闭了。System.out.println("Sent:"+msg); }}
然后我有一个订阅应用程序，它可以使用消费者或读者，但它启动后，出版商完成，我需要它只阅读最新消息发布之前，我认为这段代码应该这样做，但不知何故，它不起作用，有任何线索，各位？
浏览 4提问于2022-03-02得票数 1
我在我的应用程序中使用了PAHO C客户端库。我确实订阅了MQTTAsync_subscribe()和QoS设置为1的主题。据我所知，1意味着一条消息至少被发送给客户端一次。我断开了订阅该主题的客户端，而发布该主题的客户端仍在向Mosquitto代理发送消息。比方说，如果我在几个小时后启动订阅者，我将获得从订阅者关闭时最后一条消息开始的所有缓冲<
浏览 40提问于2020-05-05得票数 0
1回答
我设置了tweepy来获取tweet，并将其写入主题TWEEPY_TOPIC和从主题中读取的流。KAFKA_TOPIC= 'TWEEPY_TOPIC', ); 还有另一个流从上面的流中读取并将其写入另一个主题(使用kafka-connect推送到elastic search )。这些API响应当前花费的时间接近0.5-1秒。 我担心的是，如果第一个
浏览 13提问于2020-07-11得票数 0
回答已采纳
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(message){}
浏览 6提问于2021-12-15得票数 0
1回答
我已经开发了应用程序，我已经将它部署到了亚马逊的EC2映像中--这一切看起来都很棒。其中一个通知可能是属性。我有几个属性文件，我使用@Value注释注入了相关的Spring。这些属性文件驻留在属性文件夹中，类路径根(classpath: properties /
浏览 4提问于2012-08-29得票数 1
回答已采纳
我使用ZeroMQ发布-订阅套接字连接两个进程。发布过程是一个传感器，其刷新速度比订阅过程快得多。我希望订阅过程只使用队列中的最新消息，而完全忽略旧消息。我曾尝试在订阅服务器上设置一个高水区标记，但这似乎会减少更新的消息，而不是更旧的消息。
有没有一个发布-订阅模式，有人可以指示我为此目的？
浏览 5提问于2014-09-19得票数 4
回答已采纳
在我的web应用程序中，我启动一个查询来收集用户的所有最新消息，然后使用onsnapshot在提要中显示这些消息。在我的应用程序中，一些消息会发布到未来，所以我只想要来自现在或更早的消息。new Date())
浏览 13提问于2019-02-21得票数 2
回答已采纳
1回答
我有一个mail表，我需要在一个查询中检索当前用户的所有传入和传出邮件。当php在结果中循环时，它基于最近发送或接收的消息构建一个主视觉，然后需要构建与最近的消息相关的先前的消息视觉(这将在页面的最新消息下看到)。(按id排序)，然后是每个会话中最新消息之后的任何先前消息
2)阅读发送给已登录用户的消息
浏览 1提问于2013-01-12得票数 1
1回答
所以我有一个应用程序可以接收来自Raspberry Pi的信息。这一切都很好，但是我不知道如何根据订阅的主题来输出文本。现在，每当状态发生变化时，我都会把所有的主题都印在另一个旁边。当关于这个特定主题的一个新的状态出现时，文本也不会消失，它们只是笨拙地划分成一个大字符串。任何帮助都将不胜感激。这是具有订阅的客户端部分： super();
this.onMessageA
浏览 5提问于2021-05-17得票数 0
回答已采纳
我使用Spring @KafkaListener和一个topicPattern。如果在此应用程序运行时，我创建了一个与模式匹配的新主题，并开始发布该主题，则侦听器应用程序将忽略这些消息。换句话说，它只会在启动时提取与模式匹配的所有主题，并听取这些主题。
最简单的“刷新”方法是什么？谢谢!
浏览 5提问于2022-03-07得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
