我需要基于message属性下的主机名来使用kafka的消息。消息在Kafka主题下从下游被丢弃，在侦听器端，2进程被配置为相同的kafka队列，但运行在两个不同的服务器/主机名上。根据属性下的主机名过滤消息以将消息路由到正确的服务器的过程是什么。例如，message 1获得了具有主机名为serverA的属性，而message 2获得了具有主机名serverB的属性。消息1应由服务器A接收，消息2应由serverB接收。
浏览 8提问于2022-03-19得票数 0
1回答
有人能建议我如何在AWS服务器上创建主题吗？我知道当我通过指定主题名发布消息时，它会自动创建主题，但是有什么方法可以在服务器上添加所有可能的主题吗？
在上面的图像中，我能够发送主题消息(test_topic)，并在服务器上自动创建该消息。有没有办法一次在服务器上创建所有主题？
浏览 1提问于2017-03-22得票数 0
回答已采纳
1回答
我有以下架构 API网关(REST Public API) --> MBus -->微服务(Windows Services)。 我已经在API Gateway中实现了基于URL的版本控制，这有助于我实现向后兼容。基于API请求，API Gateway将请求转换为消息总线，并针对特定的服务侦听发送主题。现在，在我的通过消息总线的微服务中，我应该如何管理API的版本以实现向后兼容性，我应该通过消息总线从API网关发送API版本，以便特定的服务知道版本并执行请求的特定版本。当微服务基于消息总线而不是基于REST时，管理跨微服务的API版本控制的标准和方法是什么？ 致以敬意， IK
浏览 13提问于2020-09-18得票数 0
2回答
我正在实现GCM来向android设备发送消息。我的服务器需要根据用户偏好设置向不同的设备发送不同的消息。目前，我考虑两种方法：
1)将用户设置保存到数据库服务器，运行查询，根据用户设置选择设备，并向这些设备发送消息。
2)我会将用户设置保存在本地android设备内存中，服务器总是会向所有设备发送消息，当设备收到消息时，它会检查本地设置，以决定是否向用户显示该消息。
假设我的应用程序需要每分钟发送消息，并且有大约50万用户，哪种方法更好？
非常感谢。
浏览 1提问于2015-08-19得票数 0
我正在尝试谷歌物联网和谷歌PubSub。我正在将MQTT消息从设备发送到我所订阅的pubsub队列(我将其称为“服务器”)。在google云控制台中，我更新了设备设置，并在设备中获得了设置消息。
google tutorial中的一切都运行得很好，但我想知道是否有可能以另一种方式设置消息传递:即“服务器”发送消息到设备使用MQTT订阅的pubsub队列。
末尾的模式让我认为只有"config“mqtt队列(/devices/XXXX/config)可以这样使用。
我需要的是从“服务器”到“设备”的一对一通信，恐怕唯一的方法就是使用配置
浏览 2提问于2018-04-25得票数 2
我正在开发我的第一个微服务，我选择将它部署到一个云函数服务中，通过Pub/Sub完成消息传递。
云函数服务由Pub/Sub主题中的事件(发布消息)触发，微服务处理消息，到目前为止还不错。我知道云函数可以保证消息的确认和传递，这很好。
云函数服务具有自动重试功能:如果我在代码中抛出异常，就会发生新的程序执行。为了避免在连续失败时循环执行，我引入了一个if条件，它检查消息的‘年龄’，因为我不想简单地丢弃消息，所以我发送/发布给另一个Pub/Sub主题，我将其命名为“我的死信队列”主题。
当我现在对所有事情都不确定时，我问你:我的方法够好吗？考虑云功能、微服务和Pub/Sub消息传递，您会做什么呢？
浏览 2提问于2021-11-17得票数 1
回答已采纳
我们需要组织一种在多个数据中心中的服务器之间交换消息的方法。消息并不重要。我们只需要能够从任何数据中心的任何服务器发送消息到任何数据中心中的任何其他服务器。
我们正在考虑使用Kafka作为这个用例的消息代理，但我们不确定它是否是一个好的选择。
正如我们所理解的，如果集群分布在多个数据中心之间，Kafka将无法正常工作(因为它必须与Zookeeper一起工作，这更像是一个单一的数据中心解决方案)。我们考虑在每个数据中心使用单独的集群。每个服务器必须连接到所有数据中心中的所有Kafka集群。这就是为什么任何服务器都可以向任何数据中心中的任何其他服务器发送消息。
因此，每个服务器都有n个连接。所有连
浏览 0提问于2017-10-29得票数 3
回答已采纳
我正在为Android开发一个应用程序，它允许我从一个用户向一群一起玩游戏的用户发送一组地理位置点，但我真的不知道从哪里开始发送这些消息。
我有一个想法，包括将消息从一个用户发送到服务器，然后让服务器将消息推送给其他用户，但我不知道如何让服务器知道将消息发送给哪些用户。
我在正确的轨道上吗？是否已经设置了处理此类问题的服务？你还有其他的建议吗？非常感谢您的评论。
浏览 4提问于2012-03-12得票数 2
2回答
我们有一个Azure服务结构的微型服务，它可以收听多个天蓝色服务总线主题(主题A，主题B)。
主题A的消息流量超过10倍，其次是主题B。为了处理服务的规模能力，我们将创建多个服务实例。
我的第一个问题是，在大多数服务实例中，由于主题B的流量较少，所以会浪费资源吗？
2是否可以为主题A和主题B的听众创建不同的微服务，并创建10x的微型服务实例来收听主题A和主题B侦听器服务的x实例？
是在蔚蓝服务总线中创建消息侦听器，每次都要继续拉消息吗？意思是不断查找/检查消息，消息是否存在。
谢谢你们的支持。
浏览 1提问于2018-03-03得票数 0
Azure服务总线及其前提版本Windows的服务总线是否为每个订阅者复制了一条消息？
例如，假设有一个有五个订阅者的主题，那么该消息是五次存储在服务总线的数据库中--每个订阅者只存储一次--还是只存储了一次带有业务逻辑的消息，以确定哪些订阅者已经读取了消息？
如果有官方网站和/或文件作为参考，那就太好了。
浏览 6提问于2016-03-06得票数 2
回答已采纳
2回答
在我们的场景中，我们有一组微服务，它们通过发送事件消息与其他服务交互。在高峰时刻，我们预计每天会收到数百万条信息。每条消息都针对一个或多个侦听器类型。我们的要求如下：
零条信息丢失。
能够动态注册特定类型的多个侦听器，以提高吞吐量。
在发送消息时，不能保证侦听器是活动的。
我们考虑了两种选择：
将每条消息发送到JMS主队列，然后该队列的侦听器将消息根据消息内容路由到特定队列，然后目标服务将侦听这些特定队列。
通过消息类型将消息发送到Kafka主题，然后目标服务将订阅相关主题并使用这些消息。
为此目的使用JMS或Kafka的缺点和优点是什么？
浏览 1提问于2018-12-31得票数 0
回答已采纳
我刚刚编写了我的第一个WCF服务，以附加到Azure服务总线并处理传入的消息。web.config看起来像：
<services>
<service name="Acme.Services.ClientManagementService.ClientManagementService" behaviorConfiguration="MyServiceTypeBehaviors">
<endpoint name="ClientManagementService" address="
浏览 0提问于2014-04-16得票数 0
回答已采纳
我在Azure云服务上运行了SignalR，并尝试使用azure消息总线跨实例进行通信。
我使用以下代码连接到消息总线：
GlobalHost.DependencyResolver.UseWindowsAzureServiceBus(
"Endpoint=sb://<snip>;SharedSecretIssuer=<snip>;SharedSecretValue=<snip>",
1, /* number of Instances */
5 /*
浏览 0提问于2013-02-06得票数 0
回答已采纳
我试图用Kafka实现一个请求/回复模式。我正在处理向这些服务发送消息的命名服务和未命名客户端，客户端可能会收到回复。许多客户端(10s-100)可能与单个服务或服务的使用者组交互。
策略一:过滤消息
第一个想法是每个服务有两个主题-- "HelloWorld“服务将使用"HelloWorld”主题，并生成对“HelloWorld”主题的回复。客户端将使用该回复主题，并对唯一的消息ID进行筛选，以了解哪些答复与它们相关。
其缺点似乎是，当许多客户端与一个服务交互时，可能会产生不必要的工作，使客户端过滤掉大量可能不相关的消息。
策略二:短暂的主题
第二个想法是为每个客户端创建一个
浏览 1提问于2019-02-27得票数 3
回答已采纳
我正在使用ActiveMQ和MQTT协议构建一个大型设备的系统，我在独立服务器上使用的模型包含两个应用程序，如下所示：
App1:企业应用程序从大量设备接收消息:设备每3分钟通过主题发布到服务器:设备？？MQTT协议？？> ActiveMQ？？-？？>用EJB订阅主题的Glassfish --> Oracle。
App2:来自Oracle的企业级应用程序扫描命令并发送到大量设备:每个设备订阅一个独特的主题，如: device.0000001，那么当服务器对设备数量较多的设备( <-- MQTT -- ActiveMQ <-- Openwire - Glas
浏览 0提问于2014-06-07得票数 1
在这两种情况下，我如何发送和接收消息？
我们正在将我们的应用程序从appengine迁移到kubernetes。我们有两个以这种方式分配的微服务：
开发环境
Service 1:在Kubernetes吊舱上运行(集群名为1)。它运行在AppEngineService 2上:运行在一个Kubernetes吊舱上(集群名为1)。它在AppEngine上运行。
问题是服务1不断向AppEngine上的服务2发送公共消息。它应该向在Kubernetes上运行的服务2发送pubsub消息。
生产环境
Service 1:在AppEngine上运行，但很快它将在Kubernetes吊舱上运行(集群名为1)
浏览 2提问于2020-04-28得票数 1
在我的场景中，我希望将消息发送到一个警报服务，该服务将处理该消息并将其发送到hipchat。
但我希望这条消息只活跃一分钟。如果hipchat被关闭(假设)，则不应该将消息发送给hipchat。
我使用kafka，所以其中一个服务将消息发送给kafka，然后消息被警报服务(它轮询服务)消耗，后者处理消息(kafka使用者)，同时检查消息的时间和时间不超过一分钟。如果没有，它会按时间顺序向hipchat发送消息。
增强：
我想要一种方法来构造一条自我毁灭的信息，这样在一分钟后我就会自动消失。有办法和卡夫卡合作吗？或者有比kafka更好的替代方案(flink/sqs)。如果是，怎么做？
浏览 3提问于2020-07-13得票数 0
我已经配置了一个活动MQ服务器，它将消息放置到一个确定的主题中，此时，配置好的Camel服务器接收该消息并通过路由将其发送到另一个服务器，当Camel服务器关闭时，活动MQ仍然继续在主题中放置消息，而当Camel开始时，这些过去的消息没有被Camel读取，有什么方法可以配置Camel来从这个活动MQ服务器启动和读取过去的消息呢？
浏览 2提问于2015-10-22得票数 0
回答已采纳
1回答
与允许我们一对一传递信息的Azure服务总线队列不同，Azure服务总线主题允许我们一对多地传递消息。这意味着我们可以向多个被称为订阅者的客户端传递相同的消息。该消息传递系统基本上是ESB系统(Enterprise )，允许进行“发布/订阅”通信。
我有多个客户端，我为每个客户端创建了主题。每当服务器向客户端发送消息时，它只会将消息放入客户端主题。如果我创建单个主题和多个订阅服务器，以便每个客户端只监听其消息，是否有可能？
浏览 3提问于2020-06-03得票数 1
回答已采纳
2回答
Kafka中的消息内容是否有最佳实践或标准化方法？ID vs整个文档Vs字段子集 没有找到任何关于这一点的指导方针，一般的建议似乎是“视情况而定”。在我们的微服务架构中，我看到了所有选项的优缺点。 此外，人们通常是根据具体情况创建所需的任何类型的消息，还是为所有类型的消息采用标准的消息格式？比如发送一个ID来调用它所在的服务，或者发送消息本身中所需的所有信息，或者两者的组合。
浏览 23提问于2019-09-17得票数 0
1回答
implementedTcp客户端Tcp服务器
服务器启动
客户端A连接
客户端B连接
客户端C连接
客户端A向服务器发送消息(但他希望发送到客户端B或C或所有客户端)
比如说..。
服务器需要将此消息发送到客户端B
How client A will send the message so that server will know that A want to
send this message to B or C etc..
客户端A和消息一起发送ID，比如客户机B，因此服务器提取ID，然后不知何故知道这将把该消息转发给客户端B？
..Or是完全错误的，我认为聊天应用程序如何工作？
浏览 4提问于2019-11-11得票数 0
1回答
新的事件驱动架构。我想创建一个微服务，它从Google /Sub主题中读取，处理消息，然后将消息放在内部Kafka主题上，用于其他服务。
我的问题是，单一的微服务应该处理消费、处理和生产信息，还是应该有独立的微服务来进行消费和处理/生产。
例如，一个负责读取Google /Sub主题并将其放到内部主题的单个阅读器微服务。第二个处理微服务(可以放大)读取内部主题，处理消息并将其放到已处理的主题上。我看到这个选项的好处之一是，任何处理问题都不会影响从Google获取消息。
如能就最佳做法提出任何建议，将不胜感激。
浏览 11提问于2022-09-10得票数 1
回答已采纳
我们正在一个IOT平台上工作，它从五月份设备中每秒钟摄取许多设备参数值(时间序列)。一旦摄入了每个JSON (在特定实例中捕获的多个参数值的批处理)，在JSON以事件驱动的方式流过许多微服务时，跟踪JSON的最佳方法是什么？
我们主要使用弹簧引导技术，所有的服务都是集装箱化的。
选项1-是将UUID关联到每个对象，然后在Redis中以幂等的方式更新状态，因为每个微服务处理都是理想的？问题是，现在每个微服务都将绑定到Redis，而且我们已经看到，随着对Redis的数量api调用的增加，Redis的性能下降了，因为它是单线程的(不过，我们可以扩展这一点)。选择2- Zipkin？
注意:如上所述，
浏览 2提问于2020-09-02得票数 0
2回答
我正在使用spring来使用来自两个Kafka主题的消息，它发送的消息格式如下所示。
@KafkaListener(topics = {"topic_country1", "topic_country2"}, groupId = KafkaUtils.MESSAGE_GROUP)
public void onCustomerMessage(String message, Acknowledgment ack) throws Exception {
log.info("Message : {} is received
浏览 1提问于2020-05-24得票数 2
回答已采纳
我们对Azure消息传递服务和功能很陌生，我们学习了不同消息服务的基本概念，比如存储队列、服务总线队列、服务总线主题和事件集线器-我们还阅读了微软的，但这更像是扇出而不是回扇，这意味着在退出过程中，当前的功能在所有资源回滚之前仍然保持不变。
一个简单的场景是，我们在azure函数启动器中保存一个对象，在成功地保存到存储中之后，我们希望发送一条公共消息给三个使用实现/触发的不同的目的地/消费者，
函数1将用于通知(signalR或电子邮件)
函数2将用于日志记录( Server)
函数3将用于继续业务逻辑。
以上所有的azure函数都将是独立/独立的，并且我们的azure函数启动器无需等待这3种
浏览 1提问于2019-08-15得票数 1
回答已采纳
我想要查看当前主题级别的活跃、死信、传输死信消息的计数。在Azure门户中，我可以看到以下服务总线队列和订阅的计数 MessageCountDataInAzurePortal 但我看不到这样的主题相关消息计数，相反，我们只有图形选项，但我们必须设置时间范围，例如过去12小时。 GraphToViewVariousMetricsForTopics 但是我想看到一个主题的当前活跃，死信，转移死信计数。难道不可以这样做吗？即使在Service bus explorer中，我也总是看到这些消息计数为零，但计划的消息计数除外 ServiceBusExplorerTopicInfo
浏览 20提问于2021-08-17得票数 1
2回答
我有一个卡夫卡的用例，我不需要运行在服务器上的某些主题的日志，有些主题发送一个的消息，而另一些则不是很多。
目前，我看到的唯一的“解决办法”是设置一个相当宽松的保留政策。
问题是，我想为服务器上的其他一些主题保留日志和持久信息，这些主题对我来说可能更重要。
我有什么选择？
理想情况下，我希望按主题丢弃日志和存储的消息。
浏览 1提问于2018-10-04得票数 0
回答已采纳
2回答
我见过这个问题的零碎部分，但没有什么能直接回答这个问题。
以下是假设的环境：
20台以Java为中心的服务器(即Tomcat / Glassfish / Jboss /任何东西)通过HTTP与客户端进行通信
服务器前面的HTTP负载均衡器不能保证将您带回到每个客户端连接的同一服务器。
其他任何东西都是可用的，技术上是明智的。(JMS / Camel / Memcached / Hazelcast /任何其他)
我们希望Joe和他的浏览器(可能使用Flash或HTML5或任何客户端技术)接收所有发布到所有20个服务器都可用的JMS主题的消息。
以下是一个例子：
Joe的第
浏览 0提问于2013-01-08得票数 2
回答已采纳
我有、Order、和服务。订单提交后，必须由OrderProcessor处理。在处理完之后，OrderProcessor应该将响应发送到订单服务，例如，失败/成功。我希望使用message (Azure ServiceBus)进行异步处理并将服务解耦。
在命令和事件方面，我看到以下结构：
ProcessOrder命令应该在ServiceBus中发布。我选择了命令消息，因为我希望处理器进行一些处理。在完成处理后，只有一个Consumer.OrderProcessedFailed或OrderProcessedSucceeded事件应该在ServiceBus中发布。因此，我的订单服务应该订阅这些事件
浏览 3提问于2021-09-13得票数 0
回答已采纳
1回答
我正在使用Bluemix消息中心服务。我需要为特定用户提供对特定主题的只读访问权限。问题是如何在Bluemix消息集线器中定义ACL？Apache kafka确实提供了方法()，但这涉及到与zookeeper的交互。我也找不到细节来连接到Bluemix消息中心服务背后的底层zookeeper。感谢你的回复。
浏览 3提问于2017-03-06得票数 0
2回答
我正在学习如何在Azure云应用程序和客户端应用程序之间进行通信，并学习了教程。
我目前有一个.exe工作进程的实例，它通过服务总线发送消息。我还有一个客户端角色，我在本地机器上运行这个角色来读取消息。但是，当我运行多个客户端实例时，每个客户端都会接收到一些消息，但没有一个得到完整的读取结果。是否可以使用队列或服务总线，以便客户机的每个实例都可以看到由工作人员生成的消息的all？
例如，3台不同计算机上的3个人可能希望独立监视同一计算机任务的状态。
浏览 4提问于2013-01-04得票数 2
回答已采纳
1回答
我使用kafka作为微服务体系结构的消息总线，因此多个服务侦听一个消息的主题。因此，服务高度依赖于要直播的主题。
但是，在许多情况下，我得到了关于主题的leader not available、broker not available和leader= - 1。
现在，我不确定是否可以依赖kafka主题，因为当平台中存在问题和原因问题时，服务会被中断。
有人能对这些主题的可靠性和可靠性有所了解吗?如果我们能够解决上述问题，我们还能恢复吗？
浏览 0提问于2018-01-24得票数 5
回答已采纳
我看过的大多数地方都建议，为了防止数据丢失，你应该创建一个“重试”主题。如果使用者失败，它应该向“重试”主题发送一条消息，该主题将等待一段设定的时间，然后将一条消息发送回“主”主题。
这难道不是一种反模式吗?因为当它返回到"main“主题时，订阅"main”主题的所有服务都会重新处理失败的消息，即使只有一个服务最初无法处理它？
是否有解决此问题的传统方法，例如将clientId放在作为重试结果的消息的标头中？我是不是遗漏了什么？
浏览 0提问于2021-05-21得票数 1
最近，我尝试了Netty服务器来开发一个聊天服务器。我已经重复使用了示例"io.netty.http.example.websocketx.server"，并通过添加通道映射、消息处理器将新消息保存到数据库等方式稍微修改了它。
通道映射将包含所有已打开的频道和订阅的聊天室id。因此，当有人向聊天室123发送消息时，当收到messageReceived函数中的消息时，服务器将将消息发送到订阅到该聊天室的所有通道。
当只有一个WebSocketServer实例时，这个方法工作得很好，但是，如何将负载平衡到多个WebSocketServers呢？当WebSocketServer #1
浏览 5提问于2014-07-09得票数 1
回答已采纳
我使用Kafka在服务之间发送消息。我使用NewTopic bean来配置分区数量，例如： @Bean
fun kafkaTopic(kafkaProperties: KafkaProperties): NewTopic = NewTopic(
kafkaProperties.topics.schedulerCalculationTopic.name,
kafkaProperties.topics.schedulerCalculationTopic.partitions,
1
) 我的问题很简单，我应该将这个bean添加到消费
浏览 45提问于2021-08-16得票数 1
回答已采纳
如果我有一个作为消息使用者连接到kafka的服务，而我读取的每一条消息都会发送到该消息偏移量，那么如果我的服务关闭并重新启动，它将从上次读取消息开始读取。我的理解是，卡夫卡将保持承诺的抵消。
现在我的问题是，我是否需要担心抵消？kafka是否会以某种方式丢失这些信息，当服务重新启动时，会根据我最初的偏移量配置从主题开始或结束读取消息吗？或者，如果卡夫卡失去了我的偏移量，它也将失去主题中的所有信息，这样从一开始就可以阅读吗？
注:我在服务上使用了spring，但不确定这是否与问题相关。
浏览 2提问于2022-02-23得票数 0
回答已采纳
我是否必须使用SQS单独使用该消息？用SNS发布我的消息，用SQS消费，我觉得很奇怪。
这是pubsub实现
export const awsSNSPlugin = fp(async server => {
const snsService = new SNS({ apiVersion: '2010-03-31' });
const publish: AWSPubSub['publish'] = async params => {
try {
const response = await sns
浏览 3提问于2022-11-04得票数 -2
回答已采纳
我们目前的ActiveMQ 5.16.1出现了问题，它在没有任何明显原因的情况下突然开始堆积消息。下图显示了ActiveMQ QueueSize：
ActiveMQ被用作JMS message broker，没有任何其他组件，例如高可用性或负载平衡。有几个生产者(在最坏的情况下大约20个)产生小的/简单的JSON消息，这些消息被发送到代理并由基于JAVA的微服务使用。微服务处理消息并将数据保存到Oracle数据库。一个请求的平均处理时间约为30ms。在这20个生产者中，只有一些同时活跃，这可能在2到10个生产者之间变化。每个生产者每3秒发送一条消息，导致每个生产者20条消息/分钟。例
浏览 3提问于2021-05-17得票数 0
当将消息排队到分区队列中时，服务总线将检查是否存在分区密钥。如果找到一个，则根据分区键选择片段。
但是当碎片满的时候会发生什么，那片段里就没有空间了。服务总线是否提供错误/消息被丢弃，或者任何其他片段将被用来存储该消息？
浏览 3提问于2017-08-23得票数 3
回答已采纳
1回答
我们使用的是Spring 和合流模式注册表、Avro和Kafka绑定器。我们已经将数据处理管道中的所有服务配置为使用共享的data主题来简化异常处理过程，并能够重播失败消息。但是，由于某种原因，我们似乎无法正确提取有效负载消息，因为具有不同模式的消息被发布到单个dlq。因此，我们正在丢失原始消息的模式。
我想知道是否有任何方法可以在dlq中维护失败消息的原始schema_id，以便它可以用于无缝重播。
浏览 0提问于2019-08-04得票数 1
回答已采纳
我希望构建一个发布/订阅分布式消息传递框架，该框架可以管理大量的消息流量，并具有代理级别的一些智能。我不知道是否有一个拓扑结构来描述这一点，但这是我要研究的模型：
示例模型A
( A)有两个正在运行的消息代理(如果可能的话，最好全部放在本地主机上，以便更容易地演示)：
经纪人-A
经纪人-B
( B)每个代理将有2个侦听器和1个发布者。
示例图
订阅服务器A1、订阅服务器A2、发布服务器A1 <-> BrokerA <-> BrokerB <->发布服务器B1、订阅服务器B1、订阅服务器B2
如果消息-X被发布到broker A，
浏览 0提问于2010-05-10得票数 3
1回答
我是第一次接触服务集成总线。我已经配置了一条总线，并将我的websphere portal服务器添加为总线成员。接下来，创建了一个主题连接工厂，并在这里选择了创建的总线，我想向服务集成总线默认主题空间发送一条消息。我不确定如何使用JMS将消息发送到缺省主题空间
浏览 1提问于2013-04-04得票数 0
回答已采纳
我的用例如下:我有一个卡夫卡主题A，它的消息“逻辑上”属于不同的“服务”，我既不处理向A发送消息的系统，也不处理这些消息。
我想从A中读取这样的消息，并根据描述服务的一列(格式是CSV风格的，但这并不重要)，将它们发送到同一集群中的每个服务主题集(让我们称之为A_1, ..., A_n)。
服务集是静态的，我现在不需要处理添加/删除。
我本来希望用KafkaConnect来完成这样的任务，但令人惊讶的是，没有卡夫卡的源/汇(我找不到票，但它们被拒绝了)。
我见过MirrorMaker2，但对于我的(简单)用例来说，这似乎是个过分的浪费。
我也知道KafkaStreams，但我不想仅仅为此编写和
浏览 1提问于2019-12-19得票数 0
回答已采纳
我有一个带有两个订阅的Azure服务总线主题。我想用发送消息连接器从逻辑应用程序发送一条消息到主题。如何将消息发送到特定订阅。现在它只使用主题名称，并且没有接受订阅名称的属性，如何实现相同的名称。
提前谢谢。
浏览 2提问于2021-03-24得票数 0
能够在不需要自定义代码的情况下将消息从一个主题转发到另一个主题将非常方便。
例如，如果所有主题都可以将消息转发到单个主题，而不是订阅多个主题的服务，那么实现订阅服务器就会简单得多。
浏览 0提问于2017-07-09得票数 2
回答已采纳
我们是否可以使用逻辑应用程序读取和删除来自蔚蓝服务总线主题的一条或多条消息？在Logic上，完整的消息操作将做什么。
浏览 1提问于2021-01-15得票数 0
回答已采纳
我正在探索WSO2 ESB 4.8.1中主题和事件的使用，我创建了一个主题，并将其订阅为在WSO2 WSAS(A)中运行的一个数据服务的端点。我假设，如果我在主题详细信息控制台的发布工具中发布了一条消息，该消息具有为A操作的传入消息定义的结构，该消息将被发送到订阅者(A)，并且所有内容都将正常工作，但它不能正常工作。为什么？我还创建了一个带有事件中介器的代理服务，并使用所创建主题的名称配置了事件中介器。然后，我使用与前面解释的相同结构的传入消息来尝试代理服务。我希望至少在WSAS Soap Tracer中获得一条传入消息，但什么也没发生。我是不是遗漏了什么？
浏览 1提问于2014-03-05得票数 1
在负载平衡的环境中，我使用GCP PubSub作为Web的后端。当前实现对负载均衡器后面的每个服务器都有一个主题，以及最终用户和服务器之间的映射。当我希望向特定用户发送消息时，我使用映射来确定要在哪个主题上发布它。
这是可行的，但它有很多移动的部分，并且需要清理主题时，通过缩小或推出更新版本的应用程序删除服务器。
我现在正在探索一个更复杂的实现，其中只有一个主题。由于每个服务器都知道它的最终用户，理论上我可以向这个单一主题发布一条消息，每个服务器都可以检查该消息，并将其与其用户列表进行比较。只有当前具有消息中指定的最终用户的Web套接字连接的服务器才会处理它。
这就引出了我的问题--我如何用P
浏览 1提问于2021-06-20得票数 1
回答已采纳
1回答
我有一个系统构建了多个微服务(java )，通过grpc和avro消息进行通信。它在使用卡夫卡队列。我的问题是:服务正在有序地积累，我的一项服务订阅了Kafka的主题，而另一项服务则在发送消息并创建它之前。我没有得到任何错误，所以这似乎是工作，但不是。这个主题当时并不存在，当它收到消息时，消费者服务不会注意到它。如果我重新启动客户端服务，它可以连接到主题并正常工作。我想解决的问题是，消费者可以创建订阅的主题，如果没有收到任何消息，也可以尝试重新连接。
浏览 0提问于2017-11-10得票数 2
回答已采纳
1回答
我们目前正在亚马逊的AWS上实现一个分布式Spring Boot微服务架构，其中我们使用SNS/SQS作为我们的消息系统： 事件由Spring Boot服务使用Spring Cloud AWS发布到SNS FIFO主题。主题将事件移交给订阅了该主题的多个SQS队列，然后这些队列依次由不同的使用者服务使用(同样是使用Spring Cloud AWS的Spring Boot )。 一切都按预期工作，但我们有时会看到生产服务上的延迟非常高。 我们的产品还没有发布(我们目前正在测试中)，这意味着我们在prod上的流量非常非常低，也就是说，每天只有几条消息。 不幸的是，我们看到消息在长时间不活动后(通
浏览 31提问于2021-09-20得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
