eckstyle] [ERROR] RESOLVED

brittytino · brittytino · commit 44f68a24afdc · 2025-10-17T06:01:27.000Z
diff --git a/core/src/main/java/kafka/automq/failover/FailoverListener.java b/core/src/main/java/kafka/automq/failover/FailoverListener.java
@@ -81,14 +81,13 @@ private Optional<FailoverContext[]> getContexts(MetadataDelta delta) {
             .map(this::decodeContexts);
     }
     
-        private FailoverContext[] decodeContexts(ByteBuffer byteBuffer) {
+    private FailoverContext[] decodeContexts(ByteBuffer byteBuffer) {
         ByteBuffer slice = byteBuffer.slice();
         byte[] data = new byte[slice.remaining()];
         slice.get(data);
         return JsonUtils.decode(new String(data, StandardCharsets.UTF_8), FailoverContext[].class);
     }
 
-
     private void onContextsChange(FailoverContext[] contexts) {
         Set<FailedNode> oldFailedNodes = recovering.keySet();
         Set<FailedNode> newFailedNodes = Arrays.stream(contexts)

Original file line number	Diff line number	Diff line change
`@@ -81,14 +81,13 @@ private Optional<FailoverContext[]> getContexts(MetadataDelta delta) {`
`81`	`81`	`.map(this::decodeContexts);`
`82`	`82`	`}`
`83`	`83`
`84`		`- private FailoverContext[] decodeContexts(ByteBuffer byteBuffer) {`
	`84`	`+ private FailoverContext[] decodeContexts(ByteBuffer byteBuffer) {`
`85`	`85`	`ByteBuffer slice = byteBuffer.slice();`
`86`	`86`	`byte[] data = new byte[slice.remaining()];`
`87`	`87`	`slice.get(data);`
`88`	`88`	`return JsonUtils.decode(new String(data, StandardCharsets.UTF_8), FailoverContext[].class);`
`89`	`89`	`}`
`90`	`90`
`91`		`-`
`92`	`91`	`private void onContextsChange(FailoverContext[] contexts) {`
`93`	`92`	`Set<FailedNode> oldFailedNodes = recovering.keySet();`
`94`	`93`	`Set<FailedNode> newFailedNodes = Arrays.stream(contexts)`