This is an automated email from the ASF dual-hosted git repository. cadonna pushed a commit to branch kip1071 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 744679541e13f3ef49f9aac8b1eb95fac5ad6310 Author: Bruno Cadonna <[email protected]> AuthorDate: Thu Nov 28 17:56:14 2024 +0100 Remove unused import --- .../java/org/apache/kafka/streams/processor/internals/StreamThread.java | 1 - 1 file changed, 1 deletion(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java index 7f45577dca8..e5208bdea97 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java @@ -24,7 +24,6 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.InvalidOffsetException; import org.apache.kafka.clients.consumer.internals.AutoOffsetResetStrategy; -import org.apache.kafka.clients.consumer.OffsetResetStrategy; import org.apache.kafka.clients.consumer.internals.StreamsAssignmentInterface; import org.apache.kafka.clients.consumer.internals.StreamsAssignmentInterface.Subtopology; import org.apache.kafka.common.KafkaException;
