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] }