kafka: improve flaky unittests

Signed-off-by: Cagri Yonca <cagri@ibm.com>

Author: CagriYonca

tests/clients/kafka/test_confluent_kafka.py

@@ -259,7 +259,7 @@ def test_confluent_kafka_poll_root_exit(self) -> None:
         agent.options.allow_exit_as_root = True
 
         # Produce some events
-        self.producer.produce(testenv["kafka_topic"], b"raw_bytes1")
+        self.producer.produce(testenv["kafka_topic"] + "-poll", b"raw_bytes1")
         self.producer.flush()
 
         # Consume the events
@@ -268,7 +268,7 @@ def test_confluent_kafka_poll_root_exit(self) -> None:
         consumer_config["auto.offset.reset"] = "earliest"
 
         consumer = Consumer(consumer_config)
-        consumer.subscribe([testenv["kafka_topic"]])
+        consumer.subscribe([testenv["kafka_topic"] + "-poll"])
 
         msg = consumer.poll(timeout=30)  # noqa: F841
 
@@ -281,14 +281,14 @@ def test_confluent_kafka_poll_root_exit(self) -> None:
             spans,
             lambda span: span.n == "kafka"
             and span.data["kafka"]["access"] == "produce"
-            and span.data["kafka"]["service"] == "span-topic",
+            and span.data["kafka"]["service"] == "span-topic-poll",
         )
 
         poll_span = get_first_span_by_filter(
             spans,
             lambda span: span.n == "kafka"
             and span.data["kafka"]["access"] == "poll"
-            and span.data["kafka"]["service"] == "span-topic",
+            and span.data["kafka"]["service"] == "span-topic-poll",
         )
 
         # Same traceId