From 364a5240832e5acf99d7d6d8a69838ab380c9860 Mon Sep 17 00:00:00 2001 From: Ofek Lev Date: Thu, 16 Jan 2020 14:34:09 -0500 Subject: [PATCH] Update imports for newer versions of kafka-python --- kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py | 2 +- kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py index 7bf96ad51d951..3256ae793d21d 100644 --- a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py +++ b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py @@ -6,7 +6,7 @@ from kafka import KafkaAdminClient from kafka import errors as kafka_errors -from kafka.client import KafkaClient +from kafka.client_async import KafkaClient from kafka.protocol.offset import OffsetRequest, OffsetResetStrategy, OffsetResponse from kafka.structs import TopicPartition from six import string_types diff --git a/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py b/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py index d0e5b4c55d35e..8c4ebf6973596 100644 --- a/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py +++ b/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py @@ -7,7 +7,7 @@ from time import time from kafka import errors as kafka_errors -from kafka.client import KafkaClient +from kafka.client_async import KafkaClient from kafka.protocol.commit import GroupCoordinatorRequest, OffsetFetchRequest from kafka.protocol.offset import OffsetRequest, OffsetResetStrategy, OffsetResponse from kazoo.client import KazooClient