节省ChronicleQueue的消费者/尾部读取偏移量
ChronicleQueue是一种高性能、低延迟的持久化消息队列，用于在分布式系统中进行可靠的消息传递。它具有高吞吐量、低延迟、持久化存储和可靠性的特点，适用于需要高效处理大量消息的场景。
在ChronicleQueue中，消费者/尾部读取偏移量是指消费者在队列中读取消息的位置。通过记录消费者的读取偏移量，可以实现断点续传、消费者故障恢复等功能。
节省ChronicleQueue的消费者/尾部读取偏移量可以通过以下方式实现：
- 使用索引：ChronicleQueue提供了索引功能，可以根据消息的索引位置进行读取，而不需要遍历整个队列。通过使用索引，可以快速定位到消费者上次读取的位置，从而节省读取偏移量。
- 定期持久化偏移量：消费者在读取消息时，可以定期将读取偏移量持久化到存储介质中，例如数据库或文件系统。这样，在消费者故障恢复时，可以通过读取持久化的偏移量来恢复消费者的读取位置。
- 使用分布式存储：将ChronicleQueue的数据存储在分布式存储系统中，例如分布式文件系统或对象存储。这样，即使某个消费者故障，其他消费者仍然可以继续读取队列中的消息，而不会受到故障消费者的影响。
- 使用多线程消费：可以通过多线程的方式来消费ChronicleQueue中的消息，每个线程负责读取一部分消息。通过多线程消费，可以提高消费的并发性，从而更快地处理消息。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ、腾讯云分布式文件存储 CFS、腾讯云对象存储 COS。
腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
腾讯云分布式文件存储 CFS：https://cloud.tencent.com/product/cfs
腾讯云对象存储 COS：https://cloud.tencent.com/product/cos
相关·内容
我正在使用ChronicleQueue来保存在我的一个应用程序中生成的事件。我想在经过一些处理后，将保存的事件以其原始的发生顺序发布到不同的系统。我的应用程序有多个实例，每个实例都可以运行单个线程附加器来将事件附加到ChronicleQueue.Although中。跨实例排序是必要的，我想了解这两个问题。 1)如何保存我的事件的读取索引的索引，这样我就不会多次读取和发布历史记录队列中的相同消息。 在下面的代码中(摘自github中的示例)，索引一直保存到我们到达队列的末尾，而我们在到达队列末尾的那一刻重新启动application.The，我们最终从一开始重新读取所有消息。我想确保对于由尾部
浏览 20提问于2020-12-20得票数 1
回答已采纳
5回答
我有一个问题，假设有一个主题T1，有两个消费者C1，C2属于两个不同的组，当前偏移量是0。我们知道Kafka维护consumer.So的偏移量，如果C1消费消息，偏移量变成1，那么如果C2消费消息，它是从1偏移量开始还是从0偏移量开始消费消息？意味着如何维护两个不同消费者组的偏移量？
谢谢
浏览 1提问于2020-02-20得票数 0
我有一个正在运行的Kafka集群，当重新启动一个应用程序(消费者)时，它会跳过一些在应用程序关闭时推送到主题的消息。
当应用程序启动时，我可以看到它读取带有偏移量100的消息，然后将偏移量101推送到__consumer_offsets。然后，当应用程序关闭时，带有偏移量101, 102 and 103的消息将被推送到主题。在应用程序重新启动后，它读取101并将其偏移量设置为104，从而跳过102 and 103。
这是我的配置：
config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaCluster);
config.put(Cons
浏览 0提问于2020-04-21得票数 0
我有一个用例，其中我有两个消费者在不同的消费者组(cg1和cg2)中，订阅了具有4个分区的相同主题(主题A)。如果两个使用者从同一个分区读取数据，其中一个失败，而另一个提交了偏移量，会发生什么情况？
浏览 1提问于2020-03-06得票数 1
我正在使用卡夫卡9，并混淆了订阅的行为。
为什么它期望group.id与订阅。
我们是否需要使用commitSync手动提交偏移量。即使不这样做，我也看到它总是从最新开始。
有没有办法从一开始就重播这些消息。
浏览 5提问于2017-02-02得票数 1
回答已采纳
2回答
当我们有多个消费者从单个分区的主题中读取时，所有消费者都有可能得到所有的消息。我已经创建了两个消费者，手动偏移commit.started，第一个消费者，2分钟后启动第二个消费者。第二个消费者正在从第一个消费者停止读取的消息中读取。有没有可能第二个消费者会从头开始阅读所有的信息。我是卡夫卡的新手，请帮帮我。
浏览 24提问于2019-02-09得票数 0
在主题类型的消息传递系统中，消费者负责在他连接到主题时报告初始偏移量。
在消费者关闭的情况下，在该主题上发布了3条新消息。当消费者上网时，他将不会阅读这3条消息。只有当4条消息发布在主题上时，才会被消费者阅读
如何确保该主题上的所有消息都已被处理？
浏览 1提问于2019-03-14得票数 0
我是kafka的新手，正在尝试理解是否有一种方法可以从上次消费的偏移量读取消息，而不是从开始读取。
我正在写一个示例案例，这样我的意图就不会偏离。
Eg:
1) I produced 5 messages at 7:00 PM and console consumer consumed those.
2) I stopped consumer at 7:10 PM
3) I produced 10 message at 7:20 PM. No consumer had read those messages.
4) Now, i have started console consumer at
浏览 0提问于2015-11-13得票数 15
回答已采纳
我已经开始我的生产者发送数据到Kafka，也开始我的消费者拉相同的data.When，我正在使用消费卡夫卡处理器(kafka版本1.0)在Apache Nifi，我在我的脑海中有几个问题，与Kafka消费者相关。
Q.1)当我第一次启动ConsumeKafka处理器时，如何读取开始消息和当前消息？
Q.2)还有在Kafka中消费者关机的情况下，如何在最后一条消费消息之后阅读消息？
我们如何在使用Apache Nifi的同时实现上述两个功能？
浏览 20提问于2018-07-30得票数 2
回答已采纳
2回答
我使用下面的代码来读取我的主题数据，即“sha test2”，但它读取的是完全不同的代码行，即20行中的10行。但是当我运行console时，它显示了所有20行代码。也就是说。bin/kafka-console-consumer.sh --zookeeper localhost:2181 --主题sha test2--from-sha
我到底做错了什么？非常感谢您的帮助。
public class KafkaTestConsumer extends Thread {
//final static String clientId = "SimpleConsumerDemoCli
浏览 3提问于2016-01-21得票数 0
2回答
我们有一个应用程序，消费者读取消息，线程执行许多操作，包括在消息被生成到另一个主题之前访问数据库。在线程上消费消息和生成消息之间的时间可能需要几分钟。一旦向新主题生成了消息，就会执行一次提交，以指示我们已经完成了对消费者队列消息的处理。由于这个原因，自动提交被禁用。
我使用的是高级消费者，我注意到zookeeper和kafka会话超时，因为我们在消费者队列上做任何事情之前花费的时间太长了，所以kafka最终在每次线程返回以从消费者队列读取更多信息时重新平衡，并且在一段时间后消费者读取新消息之前开始花费很长时间。
我可以将zookeeper会话超时设置得非常高，以避免造成问题，但随后我必须相应地
浏览 2提问于2014-12-20得票数 9
回答已采纳
2回答
使用Kafka(v2.11-0.10.1.0)-spark-streaming(v-2.0.1-bin-hadoop2.7).
我有Kafka生产者和Spark-streaming消费者来生产和消费。一切正常，直到我停止消费者(大约2分钟)并重新开始。消费者启动并读取数据，绝对完美。但是，我迷失了2分钟的数据，其中消费者是关闭的。
Kafka consumer/server.properties保持不变。
带有属性的Kafka生产者：
Properties properties = new Properties();
properties.put
浏览 16提问于2017-01-18得票数 0
我刚接触Kafka，我并不真正理解Kafka配置的含义，有没有人能给我解释一下更容易理解！
下面是我的代码：
val kafkaParams = Map[String, Object](
"bootstrap.servers" -> "master:9092,slave1:9092",
"key.deserializer" -> classOf[StringDeserializer],
"value.deserializer" -> classOf[StringDeserializer],
&#
浏览 0提问于2017-07-05得票数 21
我正在使用Kafka作为消息传递应用程序。对于这个应用程序，有一个生产者将消息放入一个主题，消费者注册到这个主题，并消费这些消息。这些消费者是Docker化的应用程序。出于自动缩放的目的，每个使用者在创建时都被注册为具有唯一ID的使用者。
假设以下场景：
Consumer1被创建为停靠容器，并使用ID Consumer1将自身注册为使用者
Consumer2被创建为停靠容器，并使用ID Consumer2将自身注册为使用者
现在，无论出于什么原因，Consumer1都失败了，取而代之的是Consumer3，它将自己作为消费者注册到kafka，ID为Consumer3。
问题是，Consumer
浏览 21提问于2019-07-16得票数 1
最近我更改了主题的名称，然后似乎我的消费者阅读了主题中的所有消息，忽略了偏移量。我想知道是否有人知道一个命令，我可以检查我的偏移量是否已被重置？
谢谢，马库斯
浏览 0提问于2019-09-06得票数 0
2回答
我目前正在探索卡夫卡作为一个初学者一个简单的问题。
会有一个生产者将消息推送到一个主题，但是火花应用程序的使用者将有n个人从kafka按摩数据并插入到数据库中(每个使用者都插入到不同的表)。
是否有可能消费者会失去同步(就像消费者的某些部分在相当长的时间内下降一样)，那么一个或多个使用者将不会处理消息并插入到表中？
假设代码总是正确的，那么在传递数据时也不会出现异常。重要的是，每条消息只处理一次。
我的问题是，卡夫卡是为我们处理这个部分，还是我们必须编写一些其他代码来确保这种情况不会发生。
浏览 8提问于2017-01-06得票数 1
回答已采纳
1回答
Kafka消息传递至少使用一次消息传递来确保要处理的每一条消息，并使用消息偏移来指示接下来要传递的消息。
当有多个使用者时，如果某个致命的消息在消息处理过程中造成了使用者崩溃，该消息会被重新传递到其他使用者并传播死亡吗？如果某些慢速消息阻塞了单个使用者，其他使用者还能继续处理后续消息吗？或者更糟糕的是，如果一个慢而致命的消息导致了消费者崩溃，它会导致其他消费者再次从其抵消开始吗？
浏览 5提问于2017-09-22得票数 0
回答已采纳
假设一个主题有两个分区。在同一组中，有两个消费者都从该主题中消费:消费者A消费分区0，消费者B消费分区1。消费者A是消费群体的领头羊。
这时，消费者B收到了来自主题的一批消息，例如消息: X，Y。在那之后，消费者B停止了。
过了一段时间，消费者A认为消费者B已经死了，决定从分区1中进行再平衡和消费。它获取消息: X、Y、Z(按顺序排列)，然后写入数据库。
之后，消费者B恢复执行，不知道一段时间过去了，继续写消息X，Y，覆盖Z的效果，然后消费者B完全失败。
有可能吗？如果是，使用消息和向上访问数据库的简单方法可能不安全。
浏览 3提问于2021-06-20得票数 0
3回答
我在一个消费者组中有两个消费者，他们分配了相同的kafka主题分区。我希望从消费者B内部获得消费者A的最后一次读取偏移量。有什么想法，如何实现这一点？
浏览 2提问于2016-08-01得票数 7
回答已采纳
在我们的应用程序中有发布者和消费者，通过swagger我们可以请求发布者发送特定类型的数据，数据量可以在10K到100K之间。然后，消费者收到相同的消息并进一步处理。 由于它是一种特定类型的数据集，我们需要知道确切的计数，有多少数据被发布，有多少数据被消耗。之前我们使用了MQ，所以我们知道10K是发布的，现在MQ是空的，所以所有的都被消费了，但是在kafka中我们不能计算出来。 有没有办法找出这一点，我知道我们可以开始在代码中计数，并打印/存储在Kafka提供的任何东西之外的地方？
浏览 55提问于2021-07-27得票数 0
如上段所述。我有IOT流。Event Hub保留期为5天。有没有办法可以查询或转储这些历史数据？
谢谢
浏览 23提问于2021-10-12得票数 0
因此，当我们的应用程序向上扩展/向下扩展时，Kafka Consumer Group会重新平衡。
例如，当应用程序按比例缩小时，其中一个使用者被终止，并且先前分配给该使用者的分区在组中的其他使用者之间分布。当此过程发生时，我的应用程序日志中出现错误，指出正在处理的消息已中止
我知道在消费者组重新平衡时，整个消费者组会暂停(即)读取任何新消息。但是，消费者在暂停之前阅读的消息会发生什么呢？我们可以优雅地处理当前正在处理的消息吗？
提前感谢！
浏览 39提问于2018-12-07得票数 1
我使用的是Java api消费者连接器。每当消费者开始阅读一个主题时，它就会从主题的开头开始阅读，并且需要相当长的时间才能赶上最新的事件。我们如何确保消费者从当前偏移量读取数据？
浏览 0提问于2016-07-29得票数 0
当hdfs不可用时，有没有办法确保数据的安全性？场景是: kafka-source，flume memory-channel，hdfs-sink。如果flume服务宕机，是否可以存储topic分区的偏移量，并在恢复后从正确的位置消费？
浏览 3提问于2016-06-12得票数 0
1回答
我对Kafka非常陌生，我们使用的是Kafka 0.8.1。
我需要做的是从topic消费一条消息。为此，我必须用Java编写一个使用者，它将使用topic中的消息，然后将该消息保存到数据库中。保存消息后，将向Java使用者发送一些确认消息。如果确认为true，则应从主题中使用下一条消息。如果acknowldgement为false(这意味着由于从主题中读取的某些错误消息，无法保存到数据库中)，则应再次读取该消息。
我认为我需要使用Simple Consumer来控制消息偏移量，并且已经完成了这个链接中给出的简单的消费者示例。
在这个例子中，偏移量在run方法中被计算为'readOff
浏览 2提问于2014-07-31得票数 3
回答已采纳
我们有一个flink流应用程序，从卡夫卡读取消息。由于某些原因，我们不得不从kafka重置命令将kafka偏移重置为最新，因为有大量堆积。我们希望flink应用程序跳过所有这些消息，并从重置后出现的新消息开始。 问题是因为flink在内部管理它的偏移量，它不知道这个重置，它现在只从后向读取msg (重置前的偏移点)，现在也不能提交偏移量。因此，每次重启flink应用程序时，它都会再次从同一点读取。因此，我们在每次重启时都有重复的msg。 我知道我们不应该在flink kafka应用中手动重置偏移量。但是我们怎样才能从中恢复过来呢。 我已经尝试将auto.offset.config设置为最新，
浏览 62提问于2021-06-19得票数 4
回答已采纳
我运行一个系统，包括一个InfluxDB、一个卡夫卡代理和产生时间序列数据的数据源(传感器)。代理的目的是保护数据库不受入站事件过载的影响，并作为接收数据的不确定格式平台。数据通过阿帕奇骆驼路线从卡夫卡传输到InfluxDB。我想使用Kafka，一种中间消息缓冲区，以防骆驼路径崩溃或不可用--这是系统中最常见的错误。到目前为止，我还没有实现对Kafka的配置，使入站消息仍然可供以后使用。如何正确配置它？
浏览 1提问于2020-11-20得票数 0
回答已采纳
librdkafka包含函数rd_kafka_position，它获取给定主题-分区的当前偏移量。但评论说：
每个请求分区的\p偏移字段将被设置为上次使用的消息+ 1的偏移量，如果没有先前的消息，则设置为RD_KAFKA_OFFSET_INVALID。
换句话说，如果还没有使用任何消息，它就不会给您提供任何有用的信息。
我对我刚刚订阅了一个主题的情况很感兴趣，并且我已经打电话给rd_kafka_seek了：
寻求一个已知的位置(在错误恢复的情况下)，或者寻求分区的最末端。
在这种情况下，我想知道的是，如果一个消息被消耗，那么下一个消息的偏移量是多少。换句话说，在第一种情况下，它应该是传递给r
浏览 6提问于2020-07-24得票数 2
1回答
我有个问题。使用Logstash将数据传输到elasticsearch时，我可以看到它在csv文件的哪一行吗？例如，名为path的字段显示我所在的csv文件。那么，是否有一个字段或方法可以显示我在csv文件中的哪一行？
浏览 15提问于2021-07-14得票数 1
回答已采纳
1回答
在查找卡夫卡日志的详细信息时，我看到了下面的细节。这是否意味着总共有17905513条消息，其中17905510条已经被读取，3条正在等待读取？
Offset logSize Lag
17905510 17905513 3
浏览 4提问于2016-02-22得票数 2
回答已采纳
这是一个基于Armando Ballaci提供的答案的"Where do zookeeper store Kafka cluster and related information?“的后续问题。 现在很明显，消费者偏移量存储在Kafka集群中的一个名为__consumer_offsets的特殊主题中。很好，我只是想知道这些偏移量的检索是如何工作的。 主题不像RDBS，我们可以在RDBS上根据某个谓词查询任意数据。例如，如果数据存储在RDBMS中，下面这样的查询可能会获得某个消费者组的特定消费者的特定主题分区的消费者偏移量。 select consumer_offset__read,
浏览 40提问于2020-07-05得票数 1
我有一个Kafka主题，这个主题有五个分区。将有5个消费者团体。每个使用者组都有一个来自该主题的服务实例。
对于同样的卡夫卡记录，每一位消费者的补偿是否是相同的？
浏览 1提问于2018-12-17得票数 4
回答已采纳
我在本地实现了带有手动偏移的高级消费者代码，但我有一个问题要问，假设如果我们不提交消息，是否有任何逻辑可以在不重新启动消费者的情况下再次读取该消息。如果我正在重新启动消费者，我能够获得该消息，但如何在不重新启动消费者的情况下获得该消息。
浏览 3提问于2016-01-29得票数 0
1回答
我希望有多个订阅者接收相同的消息，比如RabbitMQ的扇出模型。
但我不知道如果订户数量达到10,000或更多，扇出模式是否有效，而且每秒钟可以有大约100-200包数据被推入。
还有什么别的办法我应该试试吗？
浏览 0提问于2018-04-06得票数 0
回答已采纳
1回答
我正在尝试使用node-rdkafka在Kafka上创建一个简单的生产者-消费者流
我使用的是debug: 'all'模式，这是我从日志中得到的：
制片人：test [0]: MessageSet with 1 message(s) delivered
消费者：Fetch topic test [0] at offset 38 (v2)
当消息产生时，消费者正在更改偏移量，这一事实使我相信与代理的连接是正确设置和验证的。
然而，由于某些原因，我没有从消费者那里得到消息本身。
此事件永远不会被调用：
consumer.on('data', function(m)
浏览 1提问于2018-11-20得票数 0
2回答
我有多个消费者群体，每个群体有一个消费者。
比如说，主题T1和PartitionP1和2个消费群体 CG1 和 CG2 CG1有一个消费者- CG1#C1，相应的CG2有CG2#C1。
现在，我们在多个消费者群体之间接收到相同的信息，这是根据设计所期望的。
我的问题是，卡夫卡如何在多个消费者群体之间保持这种抵消。如果一个消费者群体在几分钟内停止工作，它就会被备份，那么它将如何从上次提交的读取中获取消息。CG1位于偏移量24和CG2‘中，然后下降到偏移量10。因此，当CG2上升时，它将如何从偏移量11开始，CG1不会受到影响。
浏览 0提问于2018-10-27得票数 2
producer发送消息% 1、% 2、% 3、%4
consumer接收消息% 1、% 2、% 3、%4
consumer崩溃/断开连接
producer发送消息5、6、7
consumer重新启动，应该从5开始接收消息，而不是从7开始
对于这种结果，我必须使用哪个offset值，以及需要做哪些其他更改/配置
浏览 1提问于2018-01-18得票数 40
回答已采纳
1回答
我是卡夫卡的新手，我试图理解卡夫卡消费者如何消费和处理卡夫卡主题的信息而不丢失信息，如果消费者在之间失败的话。
例如：
有一个名为cart_checkout的卡夫卡主题，当用户成功地签出他们的购物车时，它只保存一个事件。它所做的就是得到一个事件，并发送电子邮件给用户，他们的项目是签出。
这是一条幸福的道路：
用户从主题中获取一个事件。Kafka.Consumer 读取偏移量被提交给email.Repeat.调用应用程序的特定函数来发送
如果应用程序在Step 3 期间失败，会发生什么？
如果消费者启动，它就会错过一个事件，对吗？(因为已提交已读取的消息)
消费者可以倒带，但它如何知道如何倒带
浏览 7提问于2022-05-06得票数 0
回答已采纳
1回答
我正在尝试实现一个循环，我们将在循环中处理一批消息，成功处理后，我们将提交消息的偏移量，但是对于下面的场景，我无法找到任何有形的输入。
Read: 1，2，3，4，5...10我将依次循环处理它们，如果消息处理成功，则只应提交偏移量。
所以想象一下，1,2成功，3失败，4,5成功，7,8失败...如果我只提交偏移量1,2,4,5，那么未提交的偏移量会发生什么? 3,7,8...
有什么想法会再读一遍吗？
浏览 1提问于2021-05-27得票数 1
我使用的是kafka版本，偏移量存储为kafka i.e._consumer_offsets
当消费者停机或不活动时，如何检索消费者偏移量？
浏览 15提问于2018-01-23得票数 2
1回答
我希望有一个Kakfa消费者能够满足两个需求：
当被请求时，it)Discard/ignore 使用所有的消息(获取所有未提交(需要帮助)的消息)
为了保持简单，我将只运行一个主题和一个分区。这就是我如何设置我的消费者：
private Consumer<Long, String> createConsumer() {
final Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
浏览 5提问于2019-12-22得票数 0
Kafka如何保证消费者不会重复阅读一条消息？
或者上面的场景是可能的吗？同一消息可以被单个或多个消费者读取两次吗？
浏览 1提问于2020-01-14得票数 3
我使用的是Kafka 0.8.1和Kafka python-0.9.0。在我的设置中，我有2个kafka代理设置。当我运行我的kafka消费者时，我可以看到它从队列中检索消息，并跟踪两个代理的偏移量。一切都运行得很好！
我的问题是，当我重新启动消费者时，它会从头开始使用消息。我所期望的是，在重启时，消费者将从它死之前停止的地方开始消费消息。
我确实试着跟踪Redis中的消息偏移量，然后在从队列中读取消息之前调用consumer.seek，以确保我只得到以前没有见过的消息。在此过程中，在部署此解决方案之前，我想与你们所有人确认一下...也许我对Kafka或者python-Kafka客户端有误解。
浏览 3提问于2014-07-10得票数 8
当我运行这个命令时，我得到了2个主题。我知道我创建了测试主题，但我看到了一个名为"__consumer_offsets“的附加主题。从名称上看，它意味着它与消费者偏移量有关，但它是如何使用的呢？
$ bin/kafka-topics.sh --list --zookeeper localhost:2181 __consumer_offsets test
$ bin/kafka-topics.sh --describe --zookeeper localhost:2181
Topic:__consumer_offsets PartitionCount:50 Re
浏览 5提问于2018-12-13得票数 3
设置卡夫卡使用者的autocommit.enable选项将导致被消耗的消息被提交，这意味着如果使用者崩溃，它将开始从最后一个提交位置读取偏移量。
但是，如果我们重新启动kafka服务器，消费者是否会重新读取已经提交的偏移量，或者在这种情况下，此选项也能工作--在服务器重新启动后，只会消耗未读消息？
浏览 2提问于2016-09-22得票数 0
回答已采纳
旧版本建议消费者连接zookeeper，新版本建议连接broker？一个社区的网友回复我说，topic的offset老版本是ZK，新版本是Kafka本身。这是这个答案的答案吗？
浏览 0提问于2018-04-27得票数 1
我有一个使用处理器api的拓扑，它更新了一个状态存储，配置了复制因子3，acks=ALL Topologies:
Sub-topology: 0
Source: products-source (topics: [products])
--> products-processor
Processor: products-processor (stores: [products-store])
--> enriched-products-sink
<-- products-source
Sink: enrich
浏览 25提问于2020-11-28得票数 3
回答已采纳
我使用一个生产者，在本地主机上运行的Kafka服务器中输入了一些消息。动物园管理员也在本地主机上。我使用ConsumerGroupExample作为给定的。
然而，消费者似乎没有收到任何信息！kafka-console-consumer.sh脚本可以提取所有这些消息，但是代码不能。怎么啦？消费者代码与该页中所给出的完全相同。
zookeeper="localhost:2181", group id = "test-a", topic = "test".
这是我发布消息的同一个主题。这是制片人的代码：
package test;
import
浏览 2提问于2015-03-27得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
