Create v3 #342
Annotations
7 errors and 1 warning
StreamsCleanUpTest.shouldDeleteState():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L675
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (2 failures)
-- failure 1 --
[All entries are once in the input topic after the 1st run]
Expecting actual:
[KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
to contain exactly in any order:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
but could not find the following elements:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
at StreamsCleanUpTest.assertContent(StreamsCleanUpTest.java:675)
-- failure 2 --
[All entries are twice in the input topic after the 2nd run]
Expecting actual:
[KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
to contain exactly in any order:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
but could not find the following elements:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
at StreamsCleanUpTest.assertContent(StreamsCleanUpTest.java:675)
|
StreamsCleanUpTest.shouldDeleteTopic():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L675
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (1 failure)
-- failure 1 --
[WordCount contains all elements after first run]
Expecting actual:
[KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
to contain exactly in any order:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
but could not find the following elements:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
at StreamsCleanUpTest.assertContent(StreamsCleanUpTest.java:675)
|
StreamsCleanUpTest.shouldCallCleanUpHookForAllTopics():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L579
Wanted but not invoked:
topicHook.deleted("through-topic");
-> at com.bakdata.kafka.HasTopicHooks$TopicHook.deleted(HasTopicHooks.java:52)
However, there were exactly 3 interactions with this mock:
topicHook.deleted(
"-output-KSTREAM-AGGREGATE-STATE-STORE-0000000008-repartition"
);
-> at com.bakdata.kafka.StreamsCleanUpConfiguration$StreamsCleanUpHooks.lambda$runTopicDeletionHooks$2(StreamsCleanUpConfiguration.java:103)
topicHook.deleted(
"-output-KSTREAM-REDUCE-STATE-STORE-0000000003-changelog"
);
-> at com.bakdata.kafka.StreamsCleanUpConfiguration$StreamsCleanUpHooks.lambda$runTopicDeletionHooks$2(StreamsCleanUpConfiguration.java:103)
topicHook.deleted(
"-output-KSTREAM-AGGREGATE-STATE-STORE-0000000008-changelog"
);
-> at com.bakdata.kafka.StreamsCleanUpConfiguration$StreamsCleanUpHooks.lambda$runTopicDeletionHooks$2(StreamsCleanUpConfiguration.java:103)
|
StreamsCleanUpTest.shouldThrowExceptionOnResetterError():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L609
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (3 failures)
-- failure 1 --
Expecting code to raise a throwable.
at StreamsCleanUpTest.shouldThrowExceptionOnResetterError(StreamsCleanUpTest.java:607)
-- failure 2 --
Expecting actual not to be null
at StreamsCleanUpTest.shouldThrowExceptionOnResetterError(StreamsCleanUpTest.java:608)
-- failure 3 --
Expecting actual not to be null
at StreamsCleanUpTest.shouldThrowExceptionOnResetterError(StreamsCleanUpTest.java:609)
|
StreamsCleanUpTest.shouldDeleteInternalTopics():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L320
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (2 failures)
-- failure 1 --
Expecting value to be true but was false
at StreamsCleanUpTest.shouldDeleteInternalTopics(StreamsCleanUpTest.java:319)
-- failure 2 --
Expecting value to be true but was false
at StreamsCleanUpTest.shouldDeleteInternalTopics(StreamsCleanUpTest.java:320)
|
StreamsCleanUpTest.shouldDeleteConsumerGroup():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L675
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (1 failure)
-- failure 1 --
[WordCount contains all elements after first run]
Expecting actual:
[KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
to contain exactly in any order:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
but could not find the following elements:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
at StreamsCleanUpTest.assertContent(StreamsCleanUpTest.java:675)
|
StreamsCleanUpTest.shouldNotThrowAnErrorIfConsumerGroupDoesNotExist():
streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java#L675
org.assertj.core.error.AssertJMultipleFailuresError:
Multiple Failures (1 failure)
-- failure 1 --
[WordCount contains all elements after first run]
Expecting actual:
[KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
to contain exactly in any order:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=bla, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty),
KeyValue(key=blub, value=2, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
but could not find the following elements:
[KeyValue(key=blub, value=1, headers=RecordHeaders(headers = [], isReadOnly = false), metadata=Optional.empty)]
at StreamsCleanUpTest.assertContent(StreamsCleanUpTest.java:675)
|
helm-lint
Node.js 16 actions are deprecated. Please update the following actions to use Node.js 20: actions/checkout@v3, azure/setup-helm@v3. For more information see: https://github.blog/changelog/2023-09-22-github-actions-transitioning-from-node-16-to-node-20/.
|