我正在使用ActiveMQ主题。我的应用程序创建一些主题，并在这些主题上创建生产者和消费者。
当生产者发送一些东西时，它会收到返回的消息，因为在同一主题中也有一个关于此主题的消费者。每个应用程序都有一个专门的主题(不同的代码，用于运行它的不同计算机)，并且有一个主要的中央核心进程，它将加入每个
浏览 7提问于2016-08-19得票数 0
回答已采纳
我正在尝试在我的Java应用程序中从相同的生产者向不同的kafka主题生成消息。 这就是我创建我的生产者并向主题发送消息的方式。producer.send(topic1, genericRecord, datasetId1);
producer.send(topic2, genericRecord, datasetId2); 然而，这两个不同的主题具有不同
浏览 46提问于2021-10-28得票数 0
1回答
randomize=true有时，我注意到所有消息最终都只发往一个代理，而另一个没有接收到一条消息。randomize=true是如何工作的？
我在上找到的唯一解释是：“使用随机算法从提供的列表中选择用于重新连接的URI”。
浏览 0提问于2012-09-29得票数 1
回答已采纳
1回答
我刚刚完成了一个关于JMS的教程，所以它对我来说是非常新的，我正在尝试理解基本知识。如果这件事重要的话，我正在使用ActiveMQ Artemis。我创建了两个简单的应用程序，一个名为Producer，另一个名为Consumer。我先运行Producer，然后运行Consumer。Consumer应用程序永远不会终止，也不会将消息打印到控制台。奇怪的是，如果我不手动终止Consumer并再次运行Producer，那么我就会看到Consumer应该在控制台上收到的
浏览 5提问于2021-12-30得票数 0
回答已采纳
我使用Kafka在服务之间发送消息。kafkaProperties.topics.schedulerCalculationTopic.name, 1
) 我的问题很简单，我应该将这个bean添加到消费者服务和生产者服务中，还是只在其中之一中添加？
浏览 45提问于2021-08-16得票数 1
回答已采纳
至少一次语义学:如果生产者收到一个确认(ack)从卡夫卡经纪人和acks=all，这意味着消息已经写了一次准确的卡夫卡主题。然而，如果生产者超时或收到错误，它可能会重试发送消息，假设消息没有写到Kafka主题。如果代理在发送ack之前就失败了，但是在消息成功地写入了Kafka主题之后，这个重试将导致消息被写入两次，从而不止一次地传递给最终的使用者。
我知道时间戳是
浏览 2提问于2020-07-18得票数 1
回答已采纳
1回答
我有一个Queue和Topic，在Activemq.If中有2条消息，我重新启动了Activemq.I，正在丢失消息，还有Topic。即使我重新启动了Activemq，我也不想丢失任何可能来自Topic和Queue.Is的消息。
我正在使用Activemq 5.8.0。
浏览 2提问于2013-09-11得票数 0
我已经在ActiveMQ中用lastImageSubscriptionRecoveryPolicy配置了一个主题。它的工作方式与预期一样，因为代理保存发送到主题的最后一条消息，并且当新的使用者订阅该主题时，它会收到最后一条消息：
使用者B订阅该主题；接收
浏览 0提问于2019-01-21得票数 0
回答已采纳
我有卡夫卡制片人的申请。是否可以在主题之前使用创建架构？无论如何，api没有提到主题中的帖
浏览 5提问于2022-08-01得票数 0
回答已采纳
1回答
我们希望使用exactly-once语义将数据存储在Kafka中，以避免消息重复。=true Kafka主题描述： Topic: topicName PartitionCount: 1 ReplicationFactor: 1 kafkaTemplate.send("topicName", "key&
浏览 86提问于2021-07-27得票数 1
回答已采纳
1回答
我正在寻找一个解决方案，其中有多个主题创建在Kafka服务器上，并基于另一个应用程序，它将尝试发布来自任何生产者的消息，但我们不知道如何启动基于生产者的相应消费者。我们目前已经实现的解决方案是，我们已经启动了所有的消费者，所有人都会倾听，当任何生产者发布消息时，它将被适当的消费者接收，这不是实现它的有效方式。有人有更好的解决方案吗？例如:主题是印
浏览 16提问于2020-12-28得票数 1
我有一个用例，其中消息来自一个通道，我们希望将其推入一个Kafka主题(多个分区)。在我们的例子中，消息顺序很重要，所以我们必须按接收消息的顺序将消息推送到主题，如果只有一个producer和单个分区，这个顺序看起来非常直接。在我们的示例中，对于负载平衡和可伸缩性，我们希望为同一个producer运行多个实例，但问题是如何维护消息的顺序。
任何想法或解决方案都会很有帮助。
浏览 2提问于2019-09-07得票数 1
回答已采纳
我在ActiveMQ中使用了一个简单的生产者和消费者的非持久性主题。生产者有时可能是空闲的，不发送任何消息。我该怎么做呢？
浏览 1提问于2012-06-21得票数 0
使用Java Client producer，可以在发布到主题之前对消息进行微调以符合模式格式。使用kafka rest proxy，如果消息无法用kafka avro模式版本反序列化，如何拒绝消息？这是为了防止不符合模式的客户端添加垃圾。我看到这个版本会自动升级到一个主题的新模式。如何限制消息发布到主题？这可能是由于所有bug的生产者客户端。
浏览 33提问于2019-11-22得票数 0
2回答
这是我的场景。该程序采用发布者/订阅者方法开发。在生产者和消费者部分有两个主题(topic1，topic2)。我需要在生产者程序中获得消费者对接收到的topic1的确认，这样当确认状态为真时，生产者程序将不得不在topic2上发送消息。
浏览 3提问于2013-01-22得票数 1
4回答
多个消费者的Activemq主题
、、、、
我现在花了很多时间研究这个问题，似乎找不到最终的解决办法。我有一个消息制作人，它应该作为一个广播机构，在两个不同的主题上发布消息。发布者的发布过程遵循以下流程：
然后，通过使用以下配置(每个使用者都有自己的clientId和dura
浏览 0提问于2014-04-08得票数 2
回答已采纳
当我们使用ActiveMQ时，我们可以信任ActiveMQ服务器的可靠性。例如，在开发非实时软件时(不需要立即发送数据)。但它应该发送)。我们是否可以相信activeMQ是确认消息传递的可靠来源。例如，我正在从生产者发送一个xml文件。将该文件发送到ActiveMQ确认的ActiveMQ传递。那么我可以信任ActiveMQ并删除xml的本地副本吗？编辑
当消息到达ActiveMQ服务器时，它是可靠的。如何确保生产者服
浏览 6提问于2015-05-25得票数 3
1回答
我们使用JBOSS 5.1.0，我们使用topic来存储我们的消息。我们的客户正在进行持久订阅以获取这些消息。一切正常，但有一个问题是我们正在从TCP客户端获取数据，我们正在处理并将其保存在主题中，它每秒发送大约10条消息，我们的客户端一次读取一条消息。这之间有一个巨大的差距，过了一段时间，JBOSS主题有很多消息，它崩溃了，说内存不足。是否有解决此问题的方法。
浏览 2提问于2012-08-28得票数 0
我想知道是否有可能让多个生产者使用相同的clientId向持久主题发送消息。在消费端，如果clientID与生产者端相同，但订阅名称不同，会发生什么情况？例如，生产者的clientId为123abc，并将消息发送到持久主题。一个消费者订阅了这个持久主题，并且这个消费者的clientId为123abc，但也有一个subscriptionName为abc123？消费者还能接收到
浏览 1提问于2020-08-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
