diff --git a/client/mqtt/publisher_test.go b/client/mqtt/publisher_test.go
index 2a85f9bf8..3c96884b4 100644
--- a/client/mqtt/publisher_test.go
+++ b/client/mqtt/publisher_test.go
@@ -35,7 +35,6 @@ func TestDefaultConfig(t *testing.T) {
 				assert.Equal(t, got.ClientID, tt.args.clientID)
 				assert.Equal(t, u, got.BrokerUrls[0])
 				assert.Equal(t, uint16(30), got.KeepAlive)
-				assert.Equal(t, 5*time.Second, got.ConnectRetryDelay)
 				assert.Equal(t, 1*time.Second, got.ConnectTimeout)
 				assert.NotNil(t, got.OnConnectionUp)
 				assert.NotNil(t, got.OnConnectError)
diff --git a/component/kafka/kafka_test.go b/component/kafka/kafka_test.go
index 5a493e5be..5164b83ea 100644
--- a/component/kafka/kafka_test.go
+++ b/component/kafka/kafka_test.go
@@ -33,7 +33,7 @@ func Test_messageWrapper(t *testing.T) {
 	assert.Equal(t, ctx, msgCtx)
 	assert.NotNil(t, consumerMessage)
 	assert.Equal(t, "topicone", consumerMessage.Topic)
-	assert.Equal(t, []byte(`{"key":"value"}`), consumerMessage.Value)
+	assert.JSONEq(t, `{"key":"value"}`, string(consumerMessage.Value))
 }
 
 func Test_NewBatch(t *testing.T) {
diff --git a/options_test.go b/options_test.go
index 6741cd79b..e76f827e2 100644
--- a/options_test.go
+++ b/options_test.go
@@ -61,7 +61,7 @@ func TestSIGHUP(t *testing.T) {
 
 		err := WithSIGHUP(nil)(svc)
 		assert.Equal(t, errors.New("provided WithSIGHUP handler was nil"), err)
-		assert.Nil(t, nil, svc.sighupHandler)
+		assert.Nil(t, svc.sighupHandler)
 	})
 
 	t.Run("non empty value for sighup handler", func(t *testing.T) {