云发布/订阅和云数据流将工作者修复到主题
我有一个谷歌云发布/订阅和云数据流处理架构，我需要有保证的消息排序。是否可以设置订阅消息流，以便每个主题的数据流工作线程是固定的，因此消息通过相同的数据流工作线程路由，因此应该实现消息排序。
谢谢
共有1个答案
当你说你需要有保证的消息排序时，你的意思是：1。在这种情况下，您可以为发布服务器中的每个事件附加一个时间戳，并使订阅者将消息存储在某个底层数据存储中。2、处理消息的顺序很重要。在这种情况下，您也应该这样做，并让订阅者检查持久存储，以了解它必须处理的下一条消息。
你可以在这个链接中阅读更多。
-
我正在构建一个Akka应用程序，并希望向外部消费者公开一些参与者的FSM状态转换。（最终目标是能够将状态转换消息推送到websocket，以便可以实时查看。）
-
目前，我已经开始使用ActiveMQ处理JMS主题。我已经通过JAVA代码（如下所述）创建了发布者和持久订阅者，并且在订阅者端也收到了消息。 Publisher.Java 订阅者.java 我对以下主题有一些疑问， 如何检查有多少订阅者使用 Java JMS 在主题中主动查找消息？ 如何从主题中获取活动和持久订阅者列表？ 我们是否可以删除主题中发布的消息？ 在这些情况下帮助我。 提前致谢。
-
我试图弄清楚GCP上是否有一项服务，允许使用发布/订阅的流，并将累积的数据转储/批处理到云存储中的文件中（例如，每X分钟一次）。我知道这可以通过Dataflow实现，但如果有现成的解决方案，我会寻找更多的解决方案。 例如，这是可以使用AWS Kinesis Firehose进行的操作—纯粹在配置级别—可以告诉AWS定期或在累积数据达到一定大小时将流中累积的任何内容转储到S3上的文件。 这样做的原因
-
我正在尝试找出是否有任何GCP数据流模板可用于使用“Pub/Sub to Cloud Spanner”进行数据摄取。我发现已经有一个默认的GCP数据流模板可用于示例-“Cloud Pub/Sub to BigQuery”。所以，我有兴趣看看我是否可以在流或批处理模式下对扳手进行数据摄取，以及行为会如何
-
我已经使用Google云数据流SDK编写了一个流式管道，但我想在本地测试我的管道。我的管道从Google Pub/Sub获取输入数据。 是否可以使用DirectPipelineRunner（本地执行，而不是在Google云中）运行访问发布/订阅（pubsubIO）的作业？ 我在以普通用户帐户登录时遇到权限问题。我是项目的所有者，我正在尝试访问发布/子主题。
-
是否有任何示例代码可以让一个主机发布事件，而另一个主机通过Esper框架接收事件（侦听器或订阅者）。我注意到Esper提供了不同的适配器（套接字、JMS和HTTP），但找不到相应的示例代码。谢谢