fix(test): allow testing of skipped test without IsTransactional panic (

IBM#2525) Signed-off-by: Mark Hindess <[email protected]> Signed-off-by: Ioan Zicu <[email protected]>
ioanzicu · Jul 31, 2023 · c1f290a · c1f290a
1 parent 0e2f1d5
commit c1f290a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/functional_consumer_test.go b/functional_consumer_test.go
@@ -233,7 +233,8 @@ func TestReadOnlyAndAllCommittedMessages(t *testing.T) {
 	ps := &produceSet{
 		msgs: make(map[string]map[int32]*partitionSet),
 		parent: &asyncProducer{
-			conf: config,
+			conf:   config,
+			txnmgr: &transactionManager{},
 		},
 		producerID:    pidRes.ProducerID,
 		producerEpoch: pidRes.ProducerEpoch,