[kafka] branch 3.5 updated: MINOR: improve ProductionExceptionHandler test (#13576)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.5 by this push:
     new a36940d3ae2 MINOR: improve ProductionExceptionHandler test (#13576)
a36940d3ae2 is described below

commit a36940d3ae222129c02fd4de607a6595d7aa8088
Author: Philip Nee <pn...@confluent.io>
AuthorDate: Fri Apr 14 13:03:45 2023 -0700

    MINOR: improve ProductionExceptionHandler test (#13576)
    
    Reviewers: Matthias J. Sax <ma...@confluent.io>
---
 .../apache/kafka/streams/processor/internals/RecordCollectorTest.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
index 0a40fb88f53..8be12d60a7e 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
@@ -1434,6 +1434,7 @@ public class RecordCollectorTest {
             final RecordCollector collector = newRecordCollector(new AlwaysContinueProductionExceptionHandler());
             collector.initialize();
 
+            assertThat(mockProducer.history().isEmpty(), equalTo(true));
             final StreamsException error = assertThrows(
                 StreamsException.class,
                 () -> collector.send(topic, true, "val", null, 0, null, (Serializer) errorSerializer, stringSerializer, sinkNodeName, context)