root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix an incorrect assignment in StreamsUncaughtExceptionHandlerIntegrationTest (#18837) 

This constructor was not initializing a field with the constructor
argument, the extra `} {` was ending the constructor body and creating
an instance initializer block that assigned the field to itself.

Reviewers: Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
Liam Miller-Cushon 2025-04-16 20:25:07 -07:00 committed by GitHub
parent effbad9e80
commit 1bb0c9a54b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java
View File

@ -183,8 +183,6 @@ public class StreamsUncaughtExceptionHandlerIntegrationTest {
private static class ShutdownProcessor<KIn, VIn, KOut, VOut> implements Processor<KIn, VIn, KOut, VOut> {
private ProcessorContext<KOut, VOut> context;
final List<String> valueList;
ShutdownProcessor(final List<String> valueList) {
@ -192,8 +190,7 @@ public class StreamsUncaughtExceptionHandlerIntegrationTest {
}
@Override
public void init(final ProcessorContext<KOut, VOut> context) {} {
this.context = context;
public void init(final ProcessorContext<KOut, VOut> context) {
}
@Override