This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c4ea6fb MINOR: Add ConfigRepository, use in Partition and KafkaApis
(#10005)
add d98df7f MINOR: Add KafkaEventQueue (#10030)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +
gradle/spotbugs-exclude.xml | 9 +
.../java/org/apache/kafka/queue/EventQueue.java | 262 +++++++++++++
.../org/apache/kafka/queue/KafkaEventQueue.java | 426 +++++++++++++++++++++
.../apache/kafka/queue/KafkaEventQueueTest.java | 243 ++++++++++++
5 files changed, 942 insertions(+)
create mode 100644
metadata/src/main/java/org/apache/kafka/queue/EventQueue.java
create mode 100644
metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
create mode 100644
metadata/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java