root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: fix broken JavaDoc links (#10890) 

Reviewers: David Jacot <djacot@confluent.io>, Luke Chen <showuon@gmail.com>
This commit is contained in:
Matthias J. Sax 2021-06-17 10:30:44 -07:00 committed by GitHub
parent d27a84f70c
commit 4d43af4a57
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server-common/src/main/java/org/apache/kafka/queue/EventQueue.java
View File

@ -55,10 +55,9 @@ public interface EventQueue extends AutoCloseable {
@Override
public void handleException(Throwable e) {
if (e instanceof RejectedExecutionException) {
log.info("Not processing {} because the event queue is closed.",
this.toString());
log.info("Not processing {} because the event queue is closed.", this);
} else {
log.error("Unexpected error handling {}", this.toString(), e);
log.error("Unexpected error handling {}", this, e);
}
}
@ -141,7 +140,7 @@ public interface EventQueue extends AutoCloseable {
* @param deadlineNs The deadline for starting the event, in monotonic
* nanoseconds. If the event has not started by this
* deadline, handleException is called with a
* @{org.apache.kafka.common.errors.TimeoutException},
* {@link org.apache.kafka.common.errors.TimeoutException},
* and the event is cancelled.
* @param event The event to append.
*/
@ -182,7 +181,7 @@ public interface EventQueue extends AutoCloseable {
enum EventInsertionType {
PREPEND,
APPEND,
DEFERRED;
DEFERRED
}
/**
@ -244,7 +243,7 @@ public interface EventQueue extends AutoCloseable {
* @param timeSpan The amount of time to use for the timeout.
* Once the timeout elapses, any remaining queued
* events will get a
* @{org.apache.kafka.common.errors.TimeoutException}.
* {@link org.apache.kafka.common.errors.TimeoutException}.
* @param timeUnit The time unit to use for the timeout.
*/
void beginShutdown(String source, Event cleanupEvent, long timeSpan, TimeUnit timeUnit);