jiafu1115 commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2481728639
##########
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/BrokerReadyCallback.java:
##########
@@ -14,16 +14,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
-package org.apache.kafka.storage.internals.log;
-
-import org.apache.kafka.common.requests.FetchRequest.PartitionData;
+package org.apache.kafka.server.log.remote.metadata.storage;
/**
- * A class containing log offset metadata and fetch info for a topic partition.
+ * Callback interface for broker ready notification.
*/
-public record FetchPartitionStatus(
- LogOffsetMetadata startOffsetMetadata,
- PartitionData fetchInfo
-) {
+public interface BrokerReadyCallback {
Review Comment:
@kamalcph @Yunyung sorry. It is my mistake. I use the IDE refactor feature
to do the refactor. it take the class into the wrong place through package name
change directly. Thanks for your good catch. I updated it and running the CI
now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
