From daf84e73d227e9738e6f2e6a31c1afb06bf71285 Mon Sep 17 00:00:00 2001 From: Mostafa Moradian Date: Wed, 22 Nov 2023 11:05:15 +0100 Subject: [PATCH] Fix faulty check in assignment to isolation level --- reader.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/reader.go b/reader.go index 010d326..39bcb49 100644 --- a/reader.go +++ b/reader.go @@ -233,7 +233,7 @@ func (k *Kafka) reader(readerConfig *ReaderConfig) *kafkago.Reader { } isolationLevel := IsolationLevels[isolationLevelReadUncommitted] - if readerConfig.IsolationLevel == "" { + if readerConfig.IsolationLevel != "" { isolationLevel = IsolationLevels[readerConfig.IsolationLevel] }