Create v3

bakdata · Apr 29, 2024 · c3945fc · c3945fc
1 parent 6cdb0d9
commit c3945fc
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java b/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java
@@ -36,7 +36,7 @@
 
 /**
  * <p>This class is primarily used to inject environment variables to the passed in command line arguments
- * in {@link ConfiguredStreamsApp} and {@link ConfiguredProducerApp}.</p>
+ * in {@link KafkaPropertiesFactory}.</p>
  *
  * <p>In general a usage would look like this:</p>
  * <pre>{@code

diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java b/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java
@@ -149,11 +149,11 @@ protected StateListener createStateListener() {
     /**
      * Create a {@link StreamsUncaughtExceptionHandler} to use for Kafka Streams.
      *
-     * @return {@code StreamsUncaughtExceptionHandler}. {@link DefaultUncaughtExceptionHandler} by default
+     * @return {@code StreamsUncaughtExceptionHandler}. {@link DefaultStreamsUncaughtExceptionHandler} by default
      * @see KafkaStreams#setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)
      */
     protected StreamsUncaughtExceptionHandler createUncaughtExceptionHandler() {
-        return new DefaultUncaughtExceptionHandler();
+        return new DefaultStreamsUncaughtExceptionHandler();
     }
 
     /**

diff --git a/...afka/DefaultUncaughtExceptionHandler.java → ...faultStreamsUncaughtExceptionHandler.java b/...afka/DefaultUncaughtExceptionHandler.java → ...faultStreamsUncaughtExceptionHandler.java
@@ -31,7 +31,7 @@
  * {@link org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse#SHUTDOWN_CLIENT}. Mimics default behavior of {@link org.apache.kafka.streams.KafkaStreams} if no {@code StreamsUncaughtExceptionHandler} has been configured.
  * @see org.apache.kafka.streams.KafkaStreams#setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)
  */
-class DefaultUncaughtExceptionHandler implements StreamsUncaughtExceptionHandler {
+class DefaultStreamsUncaughtExceptionHandler implements StreamsUncaughtExceptionHandler {
     @Override
     public StreamThreadExceptionResponse handle(final Throwable e) {
         return StreamThreadExceptionResponse.SHUTDOWN_CLIENT;

diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java b/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java
@@ -58,7 +58,7 @@ public class StreamsExecutionOptions {
      */
     @Builder.Default
     private final @NonNull Supplier<StreamsUncaughtExceptionHandler> uncaughtExceptionHandler =
-            DefaultUncaughtExceptionHandler::new;
+            DefaultStreamsUncaughtExceptionHandler::new;
     /**
      * Defines if {@link ConsumerConfig#GROUP_INSTANCE_ID_CONFIG} is volatile. If it is configured and non-volatile,
      * {@link KafkaStreams#close(CloseOptions)} is called with {@link CloseOptions#leaveGroup(boolean)} disabled