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

[mjsax]

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

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


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

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

    MINOR: improve ProductionExceptionHandler test (#13576)
    
    Reviewers: Matthias J. Sax <matth...@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)