diff --git a/serverspec/kafka/confluent.rb b/serverspec/kafka/confluent.rb
index 4fdcc5d0d..a453dd9d7 100644
--- a/serverspec/kafka/confluent.rb
+++ b/serverspec/kafka/confluent.rb
@@ -1,7 +1,8 @@
 require_relative "../spec_helper"
 require "rdkafka"
 
-describe "rdkafka", :if => !centos8?(os) do
+if ["redhat", "amazon"].include?(os[:family])
+describe "rdkafka" do
   it "can receive message via Rdkafka client" do
     config = {
       "bootstrap.servers": "localhost:9092",
@@ -19,7 +20,7 @@
   end
 end
 
-describe "fluent-plugin-kafka", :if => !centos8?(os) do
+describe "fluent-plugin-kafka" do
   it "can receive message via fluent-plugin-kafka" do
     `echo "Hello, fluent-plugin-kafka" | /usr/bin/kafka-console-producer --broker-list localhost:9092 --topic test`
     Dir.glob("/tmp/log/td-agent/*.log") do |path|
@@ -29,3 +30,4 @@
     end
   end
 end
+end