1回答
它们按不同的主题进行分类。但是它所属的主题是在它的内容中设置的。例如，这样的消息属于topic machine。2021/7/21机器323中国杭州 如何控制kafka分发到不同的topic，直到收到消息才知道要发送哪个topic？
浏览 23提问于2021-07-13得票数 0
1回答
我正在尝试使用laravel eloquent获取引用表的最后一行。我有一个引用MessageParticipant模型的User模型(返回用户参与的所有消息主题){}public functio
浏览 3提问于2018-08-12得票数 2
我们能够对特定主题执行所有的CRUD操作。我们的新需求是获取主题的消息数量，主题的所有消息的大小，每个主题分区的最后一个偏移量。输入: Broker列表和主题预期输出，5个分区如下所示 "total": 10, 3, 1, 1 "offsets": [ 9,
浏览 2提问于2019-01-22得票数 0
1回答
如何在消费前获取模式？
、、、
我使用python confluent-kafka 1.5.0和模式注册表来消费来自kafka的avro消息。
我只是消费者，没有访问管理生产者或经纪人或其他东西。我知道主题名称，并从消息字段中获取主题和命名空间，还可以在架构注册表客户端、sr客户端使用schema_id从消息中获取架构。根据我的目标，在我开始消费之前，我需要方法获取模式(只有id或主题名称)。也就是说，我希望通过主题名称手动获取模
浏览 10提问于2021-10-09得票数 0
我需要在Mule API中使用Kafka主题中的消息。Publisher将向该主题发布数百万条消息。使用者不应被要求为其所需的消息获取每条信息并进行筛选。我想知道我们是否只能根据使用者属性文件中的任何配置从主题中获得匹配特定值的消息？例如：{"Region": "XXX
浏览 3提问于2020-03-26得票数 0
回答已采纳
我为在做了一个例子。但是，只要运行请求子命令，就会得到类似于msg.Data={"stream":"my_stream2", "seq":112}的答复，尽管我没有运行reply子命令。$ nats-server -js$ ./nats-stream-example
浏览 5提问于2022-07-04得票数 2
我们有一个逻辑应用程序运行在高可用性模式下从消息队列读取。让它从消息队列中读取，确保只有一个逻辑应用实例可以处理它。现在，我们需要将队列更改为一个主题，如果我正确理解它，就意味着我们失去了确保只有一个逻辑应用程序实例处理消息的能力。那么，我的问题是，是否有一种方法可以使逻辑应用程序具有高可用性，从主题中读取，并确保只有一个实例在消息到达时处理给定的消息？
浏览 0提问于2018-08-02得票数 1
回答已采纳
我们是否有任何选择，如获取最近的10/20/等，消息从Kafka主题。我可以看到-- from - some选项来获取主题中的所有消息，但如果我只想获取一些消息，首先，最后，中间或最近10。
浏览 3提问于2018-10-03得票数 4
我知道MQTT客户端可以通过订阅$SYS/ client / reply - to来获取他们的点对点( P2P )主题。这将返回客户端将要订阅的P2P主题。但是，它们需要在消息体中传递这个P2P主题，以便消息的订阅者以请求/回复模式进行回复。有没有办法减少在消息体中传递P2P主题的开销?我们可以使用SEMP获取P2P主题吗？
谢谢。
浏览 1提问于2016-06-08得票数 0
我想要一个订阅，接收发送到主题的所有消息。我想要一个订阅，它可以接收所有与其他现有订阅的过滤器不匹配的消息。我可以选择其中之一，但不能同时获得两个。在使用订阅创建主题的基本示例中，订阅有一个默认规则，其筛选器为1=1。即发送到该主题的所有消息都将发送到该订阅。示例表明，此订阅可以用作该订阅的审计跟踪。PostTopic
Subscription-MessageType-Known获取设置了MessageType属性的所有消息。- Subscriptio
浏览 2提问于2014-02-28得票数 0
我有一个服务总线，里面已经有消息了。目前我正在创建一个带有SqlFilter的订阅-假设过滤器是(myProperty < x)。是否有某种方法可以标记订阅，以获取在创建订阅之前已在队列中的消息？
浏览 2提问于2012-12-13得票数 2
1回答
卡夫卡主题顺序
、、
我有一个使用如下代码的Kafka连接器：FROM table1 ON v.tID = id 322633324084我已经指定了连接器拉动递增，因此连接器附加了以下内容：这就是我困惑的地方。在此连接
浏览 16提问于2019-11-07得票数 2
回答已采纳
我有一个Kafka集群，它的主题每天接收数千条消息，我想看看每天有多少条消息进入该主题。我正在使用JMX exporter获取一些指标，目前我可以看到主题中的消息率，但不知道如何解决这个问题。这是我用来获取每秒消息量的公式：sum without(instance)(rate(kafka_server_brokertopicmetrics_messagesin_total{job="kafka
浏览 81提问于2019-06-01得票数 0
为了从主题中获取消息计数，我调用了WSO2 MB 3.1.0 AdminService api调用。它适用于队列，但不适用于主题。当调用主题时，它没有给出正确的计数(它总是给出0)
从队列中获取消息计数msgPattern>**queue**</xsd
浏览 3提问于2018-10-25得票数 1
我正在使用spark-streaming和Kafk，我正在尝试使用以下方法获取Kafka消息的主题：这样做的目的是以不同的方式处理来自每个主题的消息，因此我需要知道每个消息的主题。
浏览 2提问于2016-11-09得票数 0
3回答
获取来自主题的所有消息
、、、
如何从Tibco中的JMS主题获取所有消息？我试着使用“等待JMS主题消息”，但是它似乎只得到一条消息，不管我在这个主题中有多少条消息。
浏览 4提问于2017-01-04得票数 0
回答已采纳
2回答
主题中的消息存储
、、
在JMS中，消息以先进先出的方式存储在QUEUE.But中，在Topic的情况下，消息是如何存储的？是否在FIFO aur中有任何其他方式？
浏览 0提问于2013-01-03得票数 1
document_id => "%{id}" action => "update"}
我面临的问题是，当我运行logstash时，它无法获取有关该主题的旧消息我的印象是，第一次运行logstash时，它会收集某个主题中尚未使用的所有消息。我检查了这是一个新的主题，并且在其中有一些消息，当logstash开始运行时，这些消息没有
浏览 5提问于2017-02-04得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
