docs

yeikel · yeikel · commit a0293ccc35a1 · 2024-12-11T22:31:33.000-05:00
diff --git a/api/src/main/java/io/kafbat/ui/client/RetryingKafkaConnectClient.java b/api/src/main/java/io/kafbat/ui/client/RetryingKafkaConnectClient.java
@@ -57,7 +57,9 @@ private static <T> Flux<T> withRetryOnConflict(Flux<T> publisher) {
     return publisher.retryWhen(conflictCodeRetry());
   }
 
-  // Adapted from https://github.com/apache/kafka/blob/a0a501952b6d61f6f273bdb8f842346b51e9dfce/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java#L35
+  // Adapted from https://github.com/apache/kafka/blob/a0a501952b6d61f6f273bdb8f842346b51e9dfce/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java
+  // We only need this class from the connect runtime and adding the entire dependency seems excessive
+  // We also only need the `message` property
   private record ErrorMessage(@JsonProperty("message") String message) {
   }
 

Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,9 @@ private static <T> Flux<T> withRetryOnConflict(Flux<T> publisher) {`
`57`	`57`	`return publisher.retryWhen(conflictCodeRetry());`
`58`	`58`	`}`
`59`	`59`
`60`		`- // Adapted from https://github.com/apache/kafka/blob/a0a501952b6d61f6f273bdb8f842346b51e9dfce/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java#L35`
	`60`	`+ // Adapted from https://github.com/apache/kafka/blob/a0a501952b6d61f6f273bdb8f842346b51e9dfce/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java`
	`61`	`+ // We only need this class from the connect runtime and adding the entire dependency seems excessive`
	`62`	+ // We also only need the `message` property
`61`	`63`	`private record ErrorMessage(@JsonProperty("message") String message) {`
`62`	`64`	`}`
`63`	`65`