ut transactional flag

records_test.go

@@ -76,7 +76,8 @@ func TestLegacyRecords(t *testing.T) {
 
 func TestDefaultRecords(t *testing.T) {
 	batch := &RecordBatch{
-		Version: 2,
+		IsTransactional: true,
+		Version:         2,
 		Records: []*Record{
 			{
 				Value: []byte{1},

tools/uncomitted-messages/kafka-console-consumer.go

@@ -9,7 +9,7 @@ import (
 
 	// when testing locally, it is way faster to edit this to reference your local repo if different
 	// if you want to do it properly but slowly you may use some dependency manager magic
-	"github.com/Shopify/sarama"
+	"github.com/FrancoisPoinsot/sarama"
 )
 
 var (