Kafka用户端故障处理和再交付
如果Kafka的一些信息没有被收回会发生什么。假设我正在同时使用消息。而一个使用者无法处理offset=20的消息,并且没有将Ack发回。但offset=21的其他消息已被消耗并返回ack。我怎么能只重放20个？
我需要将消息放入DLQ并再次消费吗？如果那里也发生故障怎么办？
共有1个答案
如果您使用组管理（由kafka分配分区），这就不可能发生--一个分区只分配给一个线程。如果您有更多的线程，它们各自使用不同的分区，每个分区都有自己的偏移量。
-
我使用camel和cxf组件从Web服务中获取一些数据。在某些情况下，Web服务返回标准的soap：fault。我有下一个步骤： 阅读cxf和camel邮件列表中的类似问题，我理解cxfendpoint应该抛出异常，如果有soap foalt，org.apache.cxf.binding.soap.soapfault类型的异常，但我不能得到它。onException子句的目标是处理soap错误异常
-
Webpack 的配置比较复杂，很容出现错误，下面是一些通常的故障处理手段。 一般情况下，webpack 如果出问题，会打印一些简单的错误信息，比如模块没有找到。我们还可以通过参数 --display-error-details 来打印错误详情。 $ webpack --display-error-details Hash: a40fbc6d852c51fceadb Version: webpa
-
我在一个独立的java应用程序中使用apache cxf client 3.2.2来调用一些soap Web服务。 试图在单向操作中获取soap故障代码和故障字符串，但没有成功。 我定义了一个自定义拦截器，但它永远不会到达handleMessage 定制拦截器的代码 } 我遇到的异常是MessageSenderEndingInterceptor（处于PREPARE\u SEND阶段）。 它正在抛出
-
根据AWS文件： worker使用Java ExecutorService任务调用记录处理器方法。如果任务失败，工作进程将保留对记录处理器正在处理的碎片的控制。工作进程启动一个新的记录处理器任务来处理该碎片。有关详细信息，请参阅阅读节流。 根据AWS文件的另一页： Kinesis客户端库（KCL）依靠您的进程记录代码来处理处理数据记录时出现的任何异常。从进程记录抛出的任何异常都被KCL吸收。为了避
-
有一种方法可以控制作业失败后在Azkaban中发生的事情，我的意思是，如果特定的作业失败，就做特定的事情，假设一个对hive的加载失败了，我想向splank发送错误，这可能吗？或者我应该创建特定的作业来插入并像python那样处理失败 谢谢
-
问题内容： 我有一个用于捕获任何分段错误或ctrl- c的应用程序。使用下面的代码，我能够捕获分段错误，但是该处理程序一次又一次地被调用。我该如何阻止他们。供您参考，我不想退出我的申请。我只是可以小心释放所有损坏的缓冲区。 可能吗？ 处理程序就是这样。 在这里，对于Segmentation故障信号，处理程序被多次调用，并且很明显MyfreeBuffers（）给我释放已释放的内存的错误。我只想释放一