Skip to content

Commit

Permalink
Style
Browse files Browse the repository at this point in the history
  • Loading branch information
therve committed Nov 6, 2019
1 parent 91aa419 commit 61902c9
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions kafka_consumer/tests/test_kafka_consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

from datadog_checks.kafka_consumer import KafkaCheck

from .common import is_supported, KAFKA_CONNECT_STR
from .common import KAFKA_CONNECT_STR, is_supported

pytestmark = pytest.mark.skipif(
not is_supported('kafka'), reason='kafka consumer offsets not supported in current environment'
Expand Down Expand Up @@ -50,11 +50,7 @@ def assert_check_kafka(aggregator, kafka_instance):

@pytest.mark.usefixtures('dd_environment')
def test_consumer_config_error(caplog):
instance = {
'kafka_connect_str': KAFKA_CONNECT_STR,
'kafka_consumer_offsets': True,
'tags': ['optional:tag1'],
}
instance = {'kafka_connect_str': KAFKA_CONNECT_STR, 'kafka_consumer_offsets': True, 'tags': ['optional:tag1']}
kafka_consumer_check = KafkaCheck('kafka_consumer', {}, [instance])
kafka_consumer_check.check(instance)
assert 'monitor_unlisted_consumer_groups is False' in caplog.text

0 comments on commit 61902c9

Please sign in to comment.