We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fea766c commit eaa4904Copy full SHA for eaa4904
api/src/test/java/io/kafbat/ui/service/MessagesServiceTest.java
@@ -238,9 +238,9 @@ void sendMessageWithProtobufAnyType() {
238
createTopicWithCleanup(new NewTopic(testTopic, 5, (short) 1));
239
240
StepVerifier.create(messagesService.sendMessage(cluster, testTopic, testMessage))
241
- .expectNextMatches(metadata -> metadata.topic().equals(testTopic) &&
242
- metadata.partition() == 0 &&
243
- metadata.offset() >= 0)
+ .expectNextMatches(metadata -> metadata.topic().equals(testTopic)
+ && metadata.partition() == 0
+ && metadata.offset() >= 0)
244
.verifyComplete();
245
}
246
0 commit comments