2回答
我需要在KafkaStream中接收一条记录，我根据逻辑将这一条记录划分为n条记录。这n个记录被推送到另一个流。这n个记录被并行处理。但我需要知道n个作业的完成情况，这样我才能发回响应。你能告诉我怎样才能做到这一点吗？
浏览 1提问于2020-02-20得票数 3
我正在编写一个Kafka消费者应用程序，其中我有一个消费者为每个分区。代码如下所示
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
System.out.printf("topic = %s, partition = %s, offset = %d, customer = %s, co
浏览 1提问于2020-10-26得票数 1
回答已采纳
2回答
我们正在努力并行我们的Kafka消费者，以处理更多数量的记录来处理峰值负载。我们已经在做的一种方式是通过在同一消费者组中旋转尽可能多的消费者和分区。
我们的消费者负责进行API调用，到目前为止，它是同步的。我们觉得让这个API调用异步会让我们的消费者处理更多的负载。因此，我们尝试使API调用异步，并在其响应中增加偏移量。然而，我们看到了一个问题：
通过将API调用设置为异步，我们可以首先获得最后一条记录的响应，并且到那时前一条记录的API调用都还没有启动或完成。如果我们一收到最后一条记录的响应就提交偏移量，那么偏移量就会变成最后一条记录。同时，如果使用者重新启动或分区重新平衡，我们将不会收到提
浏览 2提问于2019-06-19得票数 2
1回答
请建议如何使用java使用值防止在RabbitMQ队列中插入重复记录。
例子：
{
"jsonObject" : {
"code" : "ABC",
"number" : "123456",
"Name" : "Narasimha"
}
}
如果RabbitMq中有一条记录可用。如果尝试使用相同的代码和数字再插入一条记录，则不应该允许插入RabbitMQ。
浏览 3提问于2017-12-06得票数 1
我正在尝试使用NET CORE 2.1制作一个消费者Kafka，这个消费者应该读取一条消息来比较时间戳和提交与否，所以这个消费者可以停留在相同的消息上，直到这个验证为真。请看我的代码：
while(true)
{
try
{
var cr = consumer.Consume(TimeSpan.FromMilliseconds(4000));
if
浏览 10提问于2019-07-23得票数 0
1回答
我正在使用sparkstreaming从Kafka消费，想想如果在消费者端发生了一些崩溃或类似的事情。我不担心复制记录，但我不能错过任何一条记录。如果我重新启动我的消费者，我将不会从我离开的地方继续。我想我可以通过检查点来做到这一点？？我不知道。但在最坏的情况下，我想检查一下从kafka主题中最古老的记录运行我的消费者的可能性。
浏览 2提问于2018-03-02得票数 0
我目前使用的是Artemis ActiveMQ 2.2.0，通过队列，我可以毫无问题地发送和接收消息。但是，我想知道如果队列中有多个消息，接收方如何才能检索最后一条消息？有没有我应该使用的特殊队列？谢谢,
浏览 4提问于2017-08-02得票数 0
我正在使用spring-kafka和spring-kafka-test版本1.0.2.RELEASE。
在我的一个测试中，我的应用程序使用KafkaTemplate和大多数默认配置设置将100条记录连续发送到EmbeddedKafka实例上的单个TopicPartion。
我使用KafkaTestUtils.getRecords(消费者)方法尝试从Kafka实例获取记录，并验证它们是否都已发送。
第一次调用getRecords时，我只收到一条记录。如果我再打一次我就能拿到剩下的99。
如果我显式地将消费者的位置设置为TopicPartition的开头，然后调用getRecords，我将得到全部
浏览 3提问于2016-08-12得票数 2
2回答
我在Spring应用程序中配置了一个kafka监听器，如下所示：
@KafkaListener(topicPartitions = @TopicPartition(topic = 'data.all', partitions = { "0", "1", "2" }), groupId = "kms")
public void listen(ObjectNode message) throws JsonProcessingException {
// Code to convert to json strin
浏览 1提问于2019-06-11得票数 1
回答已采纳
1回答
生产者-消费者和数据库队列
、、、、
我有一个生产者消费者机制，我被迫将生产的项目存储在数据库中，这是一个要求。另外，我有几个生产者和几个使用者，生产者和使用者线程将访问几个数据库表中的记录；ProcessID列将确定哪个线程正在访问什么记录。
线程将通过windows服务工作。
创建ProcessID有三个原因。
1-如果线程不优雅地终止，将使用processID来避免重新启动处理。
2-线程是通过数据库锁定来同步的，希望我只获得行锁，而且很可能在短时间内会有几个阻塞的线程，因为每个线程都将访问少数标记为ProcessID的记录。
我想跟踪哪个线程在哪个线程上做了什么，因为我正在将错误记录到数据库中。请注意，使用者将
浏览 3提问于2013-07-02得票数 1
回答已采纳
我明白，随机访问效率很低。但是应用程序失败了，记录内容(让我们假设它)很大，不适合日志记录或其他不合适的内容(这是真的，没有假设)，所以我只有信息，记录在这个偏移量失败了，以及为什么。很好，现在我想看看这些数据，比如说能够复制它。怎么做？
好的，我可以使用ConsumerSeekAware使用者，但这将倒带位置和处理所有记录从该位置开始。我不想那样，我只想要一个具体的信息。对于此用例，我可以在特定的使用者组中使用特定的使用者不影响其他人，并将ConsumerConfig.MAX_POLL_RECORDS_CONFIG设置为1，这样每次拉手只返回1条记录，但这不会阻止所有记录到达侦听器。因为没有
浏览 0提问于2018-10-30得票数 0
回答已采纳
2回答
卡夫卡主题分隔偏移位置总是从0或随机值开始，如何确保消费者记录是分区中的第一条记录？有什么办法能查出来吗？如果有的话请告诉我。谢谢。
浏览 2提问于2016-06-02得票数 0
我有两个微型服务。
MProducer -向kafka队列发送消息
MConsumer -从kafka队列中读取消息
当使用者崩溃并重新启动时，我希望继续使用上一条消息。
consumer = KafkaConsumer(bootstrap_servers='localhost:9092',
auto_offset_reset='latest',
enable_auto_commit=False)
浏览 1提问于2018-07-19得票数 1
回答已采纳
当一个新的消费者上线时，我很困惑rabbitmq是如何工作的。
我知道当前有x个消费者连接，然后生产者发送一条消息，消费者将收到这些消息。
但是假设consumerX停机了，现在又上线了，或者它是一个全新的消费者。是否可以回放过去24小时内的消息？
浏览 0提问于2016-09-15得票数 0
当通过kafka consumer API检索消费者指标时，即使使用kafka- consumer -groups.sh工具描述消费者组，记录-滞后-最大值偶尔也会返回0。metrics.sample.window.ms默认设置为30s，metrics.num.samples默认设置为2。metrics.num.samples如何影响记录-滞后-最大值的计算？
浏览 29提问于2019-10-25得票数 0
回答已采纳
1回答
我对Kafka非常陌生，我们使用的是Kafka 0.8.1。
我需要做的是从topic消费一条消息。为此，我必须用Java编写一个使用者，它将使用topic中的消息，然后将该消息保存到数据库中。保存消息后，将向Java使用者发送一些确认消息。如果确认为true，则应从主题中使用下一条消息。如果acknowldgement为false(这意味着由于从主题中读取的某些错误消息，无法保存到数据库中)，则应再次读取该消息。
我认为我需要使用Simple Consumer来控制消息偏移量，并且已经完成了这个链接中给出的简单的消费者示例。
在这个例子中，偏移量在run方法中被计算为'readOff
浏览 2提问于2014-07-31得票数 3
回答已采纳
我正在尝试向mysql数据库添加一条记录，然后立即检索该记录的id。我希望使用mysql_insert_id()，但是我想知道它是拉出最后一条记录还是拉出您插入的最后一条记录？
我在想，如果网站的两个用户都运行查询，那么添加的最后一条记录可能不是该用户的记录，那么mysql_insert_id()是区分这两个用户还是只是拉出最后一条记录？
谢谢。
浏览 0提问于2011-09-02得票数 0
回答已采纳
我有多个使用者，它们都使用相同的group.id侦听特定的主题。该主题有一个分区。
我的理解是，来自相同消费者组(由相同的group.id标识)的消费者将以循环方式获得消息，这样一条消息只由一个消费者处理。使用者在不同机器上的不同Windows服务中运行。
消费者是基于用C#编写的。
配置如下：
var config = new Dictionary<string, object>
{
{"group.id", "MyConsumerGroupId"},
{"en
浏览 1提问于2017-12-28得票数 0
给定主题名称、分区号和偏移量，如何从主题中只读取一条记录？
在基于Sprng Boot的应用程序中，我使用Kafka导入业务数据。导入记录被发送到import_queue，并由一个或多个业务模块使用。即使使用者未能从记录中导入数据以继续从以下记录导入数据，记录也始终被确认。
稍后，用户(在修复了一些依赖的业务数据之后)可以决定重新发送一个或多个失败(但已确认)的导入记录。
每个记录的偏移量、分区号和主题名称在我的应用程序内部存储在SQL数据库中。
从参考文档和一些StackOverflow问题中，我发现我必须：
设置容器(使用者/侦听器)
倒带(寻求)到想要的偏移量
读一条记录
浏览 1提问于2019-02-14得票数 2
回答已采纳
1回答
我们有一个MySQL表，每天收到大约500万条记录。
每个记录都需要一点时间来处理与其相关的一些元数据。因此，我们有一个“生产者”进程，它将每个记录ID发送到消息队列(SQS)。
然后，我们有50个“消费者”，它们将提取每个ID并执行必要的处理任务。
这种模式效果很好。然而，数据量继续增长。我们的单个生产者不再能够跟上插入到表中的数据量。
我知道，我们可以增加更多的消费者，以加快处理。但是，在不发生ID冲突的情况下，加速生产者的好策略是什么呢？
更新
以下是表的结构：
id int(10) AUTO_INCREMENT
name varchar(255)
is_processed ti
浏览 0提问于2018-04-30得票数 0
回答已采纳
2回答
如何正确地进行线程处理？
、、、、
我一直在学习.Net线程，并学习了Threading.Task和Threading.Task.Parallel类。现在，使用ForEach类的Parallel方法，我在一个单独的线程上处理每个对象。但是，我认为ForEach方法等待所有线程在返回之前完成执行。这会导致那些线程在其他线程之前结束而处于空闲状态。我想让这些线程不断地工作。所以这就是我希望做的
我让线程A负责从表中选择记录，然后启动n个工作线程来处理每条记录。
每当工作线程完成其任务时，它都应该要求线程A处理下一条记录。
当将记录分配给工作线程时，如果线程A运行完，它应该返回到数据库并获取更多的记录。我猜这个分配过程必须包装
浏览 2提问于2011-07-08得票数 0
回答已采纳
当我在合流云上使用Kafka时，我发现了一种奇怪的行为。我创建了一个具有默认分区值的主题: 6。
我的系统包括一个向该主题发送消息的Java生成器应用程序和一个Kafka流应用程序，该应用程序从该应用程序中读取并执行每条消息的操作。
----------------------- -------- -----------
| Kafka Java Producer | ----> | topic | ----> | KStream |
----------------------- --------
浏览 0提问于2019-07-19得票数 2
回答已采纳
我想写一个函数，一旦主题中的最后一条消息被读取，它就会调用回调。
function getCurrentMessages(kafka, topic, cb_done){
// Start consuming from the beginning
var consumer = new kafka.Consumer(new kafka.Client(), [{topic: topic, offset: 0}], {fromOffset: true});
consumer.on('message', function(msg){
// Do something w
浏览 3提问于2015-10-03得票数 0
我正在用RabbitMQ编写一个系统。我已经将其用于工作队列，正如它们的所描述的那样。很简单也很简单。当我们向队列发布消息时，我知道将由谁来处理:生产者和消费者在一对一的关系中耦合(到目前为止这是正常的)。
我现在想做更复杂的事情(消费者和生产者之间的关系)：
制作者发布一条信息，不知道如何处理它。(发送事件)
不同的使用者对同一条消息进行不同的操作(例如，统计和日志记录)
我们可以运行多个使用者类型的实例(假设有3个统计使用者和2个日志使用者)
每条消息都可以由所有使用者类型进行处理。
每条消息必须由每个消费者类型(竞争的消费者)处理一次。
当我阅读文档时，我不知
浏览 6提问于2014-05-21得票数 0
我在没有指定kafka组id的情况下运行pyspark structured streaming，每次运行程序时，我发现记录器消息中的group.id总是被更改。我搞不懂，如果它改变了group.id，它怎么知道下一次从哪里开始消费，或者我应该手动设置kafka的偏移量？我怎么知道它自动生成的主题id是否与我手动设置的其他主题id冲突？
浏览 2提问于2020-01-08得票数 0
我们使用activemq作为Java独立应用程序的消息队列。我的问题是，基于activemq web控制台，队列有一定数量的消息入队和出队。然而，根据我在代码中添加的sysout语句，应用程序消耗的消息似乎少于activemq web控制台上显示的消息数量。例如，在activemq控制台上，no。入队和出队的消息数约为1800。但是，在控制台上显示的出队消息数(我每收到一条消息就递增一个计数器)只有1700条左右。
我真的不知道大概在哪里。发送了100条消息。所以我在想，如果我知道如何让activemq记录由生产者入队和由消费者出列的消息，我可能会有一些想法。这个是可能的吗？若有，如何处理？
浏览 0提问于2013-11-06得票数 1
我使用的是1.5.4 spring boot，java 8和kafka 2.2.0版本。我有5个代理和4个不同的主题，每50个分区。
我有一个这样的系统：
我有两三百万张唱片。我出口这些记录的2500,2500部分上的每个卡夫卡消息。我的意思是1条kafka消息由2500条记录组成，但我使用的是相同的键，这意味着所有这些记录都会进入相同的分区。我使用紧凑的主题，也有2-3百万的记录，我使用ktable - kstream连接和收集另一条记录。(此记录具有不同的键，如Id，以便重新分区)在此连接操作之后，我返回到我的原始键进行重新分区。我的kafka streams代码监听这个主题，并执行重新分
浏览 0提问于2019-11-14得票数 0
1回答
我试图用kafka-python构建一个应用程序，在这个应用程序中，使用者从一系列主题中读取数据。非常重要的是，消费者不会两次阅读同一条消息，但也不会错过一条消息。
一切似乎都很好，除了当我关闭消费者(例如失败)，并试图开始阅读从抵消。我只能读取主题中的所有消息(这会创建双读)，或者只侦听新消息，只监听(并且错过了在故障期间发出的消息)。当暂停消费者时，我不会遇到这个问题。
为了解决这个问题，我创建了一个孤立的模拟。
在这里，通用生产者：
from time import sleep
from json import dumps
from kafka import KafkaProducer
浏览 2提问于2018-08-11得票数 9
回答已采纳
在Kafka中，一个消费者可以订阅的主题的最大限制是什么。我在任何地方都找不到这个记录的值。
如果消费者订阅了500000个或更多的主题，性能是否会下降。
浏览 6提问于2017-09-19得票数 5
1回答
目标:读取主题中的所有消息，然后终止该过程。
我可以通过以下内容连续阅读消息：
props.put("bootstrap.servers", kafkaBootstrapSrv);
props.put("group.id", group_id);
props.put("max.poll.records", 1); // Only get one record at a time. I understand that to read all messages this will need to be increased
props.put("
浏览 16提问于2018-12-14得票数 3
回答已采纳
如何忽略最后一条记录，选择其他记录，并赋值给mongodb中的变量。我尝试获取用户id -862..How的最后一条记录，以获取除最后一条记录之外的其他记录。 db.product_logs.find({"user_id" :"862"}).sort({"_id":-1}).limit(1)
浏览 15提问于2021-04-20得票数 0
2回答
我制作了表会话和表 messages ，每个会话都有许多消息，我想显示会话的最新消息，所以我使用以下方法
$conversation->messages->last()->body
它返回记录中的最后一条消息，而不是最新消息，
这是我的记录
最近的消息不是最后一条记录，当我插入新消息时，它不是在最后一条记录中，而是以某种随机顺序插入的，这使得最后()不能正常工作，
浏览 8提问于2022-09-08得票数 -3
回答已采纳
我的程序接收消息的速度将相当慢；我希望它们在队列中持续存在，直到我接收到所有消息并确认所有消息。我不知道我是否有足够的消息，直到我收到一堆消息。
我的问题是:在传递第二条消息之前，队列是否会阻塞，等待来自第一条消息的确认？
浏览 1提问于2013-01-29得票数 2
Kafka如何保证消费者不会重复阅读一条消息？
或者上面的场景是可能的吗？同一消息可以被单个或多个消费者读取两次吗？
浏览 1提问于2020-01-14得票数 3
我想实现一些类似于MQTT的“保留消息”行为的东西。我想附上一个消费者，并立即开始阅读最近发送的信息。看来应该给我我想要的东西。
我有点卡住了，因为可以将偏移量设置为last ()，它开始读取最后一个消息块。但我要找的是最后一条信息。
也就是说:当我订阅时，我看不出如何确定当前块中的最后一条消息。
是否有方法将偏移量设置为流中的最后一条消息？
浏览 7提问于2022-12-01得票数 0
在社区的帮助下，我现在有了一个很棒的输入表单，需要进行一些调整:请注意六条记录的示例：
如果我前进(“下一条记录”按钮)或“后退”(“上一条记录”按钮)一次浏览一个记录，或者“转到第一条记录”(使用“第一条记录”按钮)，它们都会正确显示。
但是，如果我从Lookup member组合框中选择任何成员，所有图片都可以正常显示，但第一条记录除外，它总是显示最后一张图像。
代码如下：
Private Sub Form_Current()
Dim strPath As String
If IsNull(Me!MemPicturePath) Then
st
浏览 1提问于2015-08-18得票数 0
我需要记录incomming请求(xml)。所以我创建了一个
public class RequestWrapper extends HttpServletRequestWrapper {
private String _body;
public RequestWrapper(HttpServletRequest request) throws IOException {
super(request);
_body = "";
BufferedReader bufferedReader = request.getReader();
Strin
浏览 0提问于2018-06-27得票数 0
回答已采纳
我目前有一个java程序，它运行一个存储过程，一次调用一个数组列表中的一条记录，该列表循环直到所有记录都被处理完。目前，从存储过程调用返回每条记录大约需要8秒。在完成调用之后，它从SP获取XML消息，并在代码中继续将该消息写入队列，然后更新数据库中的一个字段以将该记录标记为已处理。 我想要做的是让x个线程一次命中/调用存储过程，以加快完整数组列表的处理时间，并像现在一样继续执行其他步骤。数组列表可以是从几百条记录到4000条以上记录的任何位置。 有没有办法在调用之后仍然通过相同的过程，但添加多线程，以一次多次命中SP，而不会出现问题？我只写了很短的一段时间，所以请耐心等待，谢谢！ publi
浏览 25提问于2019-01-10得票数 0
1回答
我们正在寻找一个新的消息传递平台，并缩小了我们的选择范围RabbitMQ或卡夫卡。
现在，我倾向于卡夫卡，但我怀疑这是一个很好的选择，鉴于我们的要求之一。
我们需要一个由未知数量的消费者使用的队列。也就是说，当“工人”在线进行处理时，我们需要动态地添加和删除消费者。此外，工人可以随时下车。
例如，我们可能会启动一个没有消费者的队列，然后消费者的数量可能会增加到30个。后来，它可能会增长到5000或更多，然后下降到3。
我们不关心这个特定用例的消息排序。卡夫卡适合这样吗？
此外，我们还计划维护一个消费者线程池，以便工作人员能够获取一条消息并处理它。因此，可能有100名消费者在池中，只有20名工人
浏览 3提问于2015-10-24得票数 2
回答已采纳
我有一个User hibernate类，Clerk类和Consumer类。所有这些映射到数据库中它们自己的表。用户PK同时充当Clerk和Consumer的PK。
所以现在我的问题是，如果用户最初是Clerk，那么他在Users表和Clerks表中都有一条记录。如果该用户希望成为消费者，我希望将该用户的记录链接到新消费者的记录。因此，即使我将userId传递给使用者的记录，它也会将其视为要持久化的新用户，并给出一个duplicate_key异常。如何告诉Hibernate将相同的user对象与这个新的Consumer对象链接起来？
浏览 1提问于2010-02-05得票数 0
2回答
我们有一个分配器，它接收一条消息，然后“扇”它到多个下游环境。
每一组下游环境都需要使用此消息。
用不同的group.ID标记不同的环境是否足以强制所有环境使用相同的消息(1生产者-多用户广播)。
如果某个特定环境(组)崩溃，是否可能只向特定组重放消息？
浏览 1提问于2019-02-05得票数 1
回答已采纳
1回答
弹簧集成-最大吞吐量消费者
、、、、
Spring集成元素的配置(如果有的话)将支持以下模型：
一个消息队列，表示传入的工作
从该队列读取数据的多个使用者(一条消息只需转到一个用户)
每个使用者只在没有工作可做的情况下才投票；如果它目前正在处理一条消息，则不要轮询。如果它没有做任何工作，每X秒轮询一次，看看新的工作是否已经到来。
浏览 1提问于2012-07-05得票数 0
回答已采纳
我们目前有一个简单的需求，就是向我们的用户提供一个记录表。每条记录都有指向存储在Azure存储中的PDF的链接。我们需要让我们的用户能够点击一条记录，并能够查看(在行中)相关的PDF。
我们目前使用SharePoint Online，不能在SharePoint中存储数据(组织政策)。
是否可以创建一个SharePoint站点/web部件等来完成上述操作？我们正在确定选项的范围。
浏览 0提问于2019-09-02得票数 0
1回答
有一个表格，记录时间戳和电表(kwh)的整数读数(date_entered，读数)。想要绘制日常使用情况的图表...大多数读数是每天的，有些读数是几天的间隔-一天中的随机时间。想要每天返回的前一条目的差值的日平均值。*注意平均值是不准确的。
Example Data:
date_entered reading
2012-06-01 17:02 18522
2012-06-02 14:56 18641
2012-06-03 10:55 18677
2012-06-06 15:16 18702
2012-06-11 13:28 18803
2012-06-13
浏览 1提问于2012-06-13得票数 1
1回答
如何选择最后两个插入的ID？
在这里，我解释了我如何使用这些。这是我的疑问：
INSERT INTO Table1 (FIELD1, FIELD2, FK_TABLE2, FIELD6)
(SELECT FIELD1, FIELD2
,(SELECT MAX(PK_Table2)
FROM Table2
)
,(FIELD4 + FIELD5) FROM Table1 WHERE FIELD3 = (
(SELECT MAX(PK_Table2)
FROM Table2) - 1
))
对于table2的最后一条记录( table2的最后一条记
浏览 2提问于2017-12-15得票数 0
回答已采纳
假设我们通过执行下面的简单代码获得了如下交换。maxPollRecords配置的kafkaEndpoint如何影响这一点。在执行以下代码之后，echange将只有一条来自kafka的消息。默认值为maxPollRecords为500。
Exchange exchange = kafkaConsumer.receive(kafkaEndpoint, 100);//ConsumerTemplate kafkaConsumer;
使用kafka库时，很明显，因为consumer.poll()将返回如下所示
ConsumerRecords<String, String> records =
浏览 1提问于2017-06-25得票数 1
回答已采纳
在附加新主题的消费者之前，我创建新主题并在apache kafka中生成第一条消息。然后附加新主题的消费者，但无法消费第一条消息。为什么..？
在本例中，已经记录了offset=1、提交的offset=1、lag=0。
“提交的offset=1”不就意味着它已经被消费了吗？我的问题是，为什么它已经被消费了。如果有什么不对劲的地方，请告诉我。
这是我的测试用例。
# create new topic
$ kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partition
浏览 0提问于2018-07-05得票数 0
正如标题中所说，我想在我的主题中获得一些记录，但我找不到使用kafka-python库的解决方案。有谁知道吗？
浏览 88提问于2020-10-07得票数 3
1回答
我正在考虑使用Apache，我找不到任何关于持久订阅的信息。假设我的分区中的消息有5秒的到期时间。现在，如果消费者在5秒后失败并重新连接，那么他错过的消息就会消失。更糟糕的是，他不会知道他错过了一条信息。持久订阅模式通过为失败或断开连接的使用者保存消息来解决此问题。卡夫卡是否实现了类似的功能？
浏览 3提问于2017-04-10得票数 0
回答已采纳
我在Kafka consumer上遇到了非常奇怪的问题。我的设置如下所示。
<prop key="enable.auto.commit">true</prop>
<prop key="auto.commit.interval.ms">10</prop>
<prop key="auto.offset.reset">latest</prop>
在我的组中有2个消费者对单个主题进行了投票。我没有在消费者端做任何手动的偏移管理。
现在，当我的消费者宕机时，我几乎没有发布关于我的主题的
浏览 10提问于2018-04-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
