Skip to content

Commit 7ee73e6

Browse files
MINOR: Accept Throwables in DeferredEventQueue.failAll (#19337)
DeferredEvents take a Throwable and not an Exception. For consistency, DeferredEventQueue.failAll should also accept a Throwable. Reviewers: David Jacot <[email protected]>
1 parent ed77397 commit 7ee73e6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server-common/src/main/java/org/apache/kafka/deferred/DeferredEventQueue.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public void completeUpTo(long offset) {
7676
*
7777
* @param exception The exception to fail the entries with.
7878
*/
79-
public void failAll(Exception exception) {
79+
public void failAll(Throwable exception) {
8080
Iterator<Entry<Long, List<DeferredEvent>>> iter = pending.entrySet().iterator();
8181
while (iter.hasNext()) {
8282
Entry<Long, List<DeferredEvent>> entry = iter.next();

0 commit comments

Comments
 (0)