We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0769959 commit 28b22a8Copy full SHA for 28b22a8
src/main/java/cn/leancloud/kafka/consumer/HandleMessageFailedException.java
@@ -1,5 +1,11 @@
1
package cn.leancloud.kafka.consumer;
2
3
+import org.apache.kafka.clients.consumer.ConsumerRecord;
4
+
5
+/**
6
+ * Thrown by {@link ConsumerRecordHandler)} when the record handler failed to handle a {@link ConsumerRecord}. The origin
7
+ * exception will be wrapped in this exception.
8
+ */
9
public final class HandleMessageFailedException extends RuntimeException {
10
public HandleMessageFailedException() {
11
super();
0 commit comments