[DO-NOT-MERGE] Release kafka_consumer 3.1.4 beta #38239
GitHub Actions / Test Results
failed
Sep 8, 2023 in 0s
1 fail, 62 pass in 6m 24s
Annotations
Check warning on line 0 in kafka_consumer.tests.test_e2e
github-actions / Test Results
1 out of 8 runs failed: test_e2e (kafka_consumer.tests.test_e2e)
artifacts/test-results/Kafka Consumer/test-e2e-py3.9-3.3-kerberos$TOX_ENV_NAME.xml [took 3s]
Raw output
AssertionError: Needed exactly 1 candidates for 'kafka.broker_offset', got 0
Expected:
MetricStub(name='kafka.broker_offset', type=None, value=None, tags=['optional:tag1', 'partition:0', 'topic:marvel'], hostname=None, device=None, flush_first_value=None)
Similar submitted:
Score Most similar
#x1B[1m#x1B[31mtests/test_e2e.py#x1B[0m:13: in test_e2e
assert_check_kafka(aggregator, kafka_instance[#x1B[33m'#x1B[39;49;00m#x1B[33mconsumer_groups#x1B[39;49;00m#x1B[33m'#x1B[39;49;00m])#x1B[90m#x1B[39;49;00m
#x1B[1m#x1B[31mtests/common.py#x1B[0m:86: in assert_check_kafka
aggregator.assert_metric(mname, tags=tags, count=#x1B[94m1#x1B[39;49;00m)#x1B[90m#x1B[39;49;00m
#x1B[1m#x1B[31m../datadog_checks_base/datadog_checks/base/stubs/aggregator.py#x1B[0m:368: in assert_metric
#x1B[96mself#x1B[39;49;00m._assert(condition, msg=msg, expected_stub=expected_metric, submitted_elements=#x1B[96mself#x1B[39;49;00m._metrics)#x1B[90m#x1B[39;49;00m
#x1B[1m#x1B[31m../datadog_checks_base/datadog_checks/base/stubs/aggregator.py#x1B[0m:410: in _assert
#x1B[94massert#x1B[39;49;00m condition, new_msg#x1B[90m#x1B[39;49;00m
#x1B[1m#x1B[31mE AssertionError: Needed exactly 1 candidates for 'kafka.broker_offset', got 0#x1B[0m
#x1B[1m#x1B[31mE Expected:#x1B[0m
#x1B[1m#x1B[31mE MetricStub(name='kafka.broker_offset', type=None, value=None, tags=['optional:tag1', 'partition:0', 'topic:marvel'], hostname=None, device=None, flush_first_value=None)#x1B[0m
#x1B[1m#x1B[31mE Similar submitted:#x1B[0m
#x1B[1m#x1B[31mE Score Most similar#x1B[0m
Check notice on line 0 in .github
github-actions / Test Results
63 tests found
There are 63 tests, see "Raw output" for the full list of tests.
Raw output
kafka_consumer.tests.test_e2e ‑ test_e2e
kafka_consumer.tests.test_integration ‑ test_can_send_event
kafka_consumer.tests.test_integration ‑ test_check_kafka
kafka_consumer.tests.test_integration ‑ test_check_kafka_metrics_limit
kafka_consumer.tests.test_integration ‑ test_config[Empty consumer_groups and monitor_unlisted_consumer_groups true]
kafka_consumer.tests.test_integration ‑ test_config[Empty consumer_groups]
kafka_consumer.tests.test_integration ‑ test_config[Invalid Non-string kafka_connect_str]
kafka_consumer.tests.test_integration ‑ test_config[Invalid Nonetype kafka_connect_str]
kafka_consumer.tests.test_integration ‑ test_config[Nonexistent consumer group, resulting in no metrics]
kafka_consumer.tests.test_integration ‑ test_config[One consumer group and one unconsumed topic for that consumer]
kafka_consumer.tests.test_integration ‑ test_config[One consumer group, all topics and partitions]
kafka_consumer.tests.test_integration ‑ test_config[One consumer group, one topic, all partitions]
kafka_consumer.tests.test_integration ‑ test_config[One consumer group, one topic, one partition]
kafka_consumer.tests.test_integration ‑ test_config[Valid list kafka_connect_str]
kafka_consumer.tests.test_integration ‑ test_config[Valid str kafka_connect_str]
kafka_consumer.tests.test_integration ‑ test_consumer_config_error
kafka_consumer.tests.test_integration ‑ test_monitor_broker_highwatermarks[Monitor all broker highwatermarks Disabled]
kafka_consumer.tests.test_integration ‑ test_monitor_broker_highwatermarks[Monitor all broker highwatermarks Enabled]
kafka_consumer.tests.test_integration ‑ test_no_partitions
kafka_consumer.tests.test_integration ‑ test_no_topics
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[All consumer offsets, all topics]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[All consumer offsets, empty topics]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[All consumer offsets, no topics]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Mixing both consumer_groups and consumer_groups_regex]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Mixing consumer_groups, consumer_groups_regex, and monitor_unlisted_consumer_groups]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Multiple consumer_groups specified]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[No consumer offsets, No topics]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[No consumer offsets, empty topics]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[No specified consumer groups, but monitor_unlisted_consumer_groups true]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified consumer group, topic, and partition]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified consumer group, topic]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified consumer with unconsumed topic regex for that consumer]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified topic with an extra nonmatching consumer group regex, monitor_unlisted_consumer_groups false]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified topic, monitor_unlisted_consumer_groups false]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified topics on consumer_groups, but monitor_unlisted_consumer_groups true]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Specified topics on consumer_groups_regex, but monitor_unlisted_consumer_groups true]
kafka_consumer.tests.test_integration ‑ test_regex_consumer_groups[Using the same consumer_groups and consumer_groups_regex values]
kafka_consumer.tests.test_unit ‑ test_oauth_config[Empty sasl_oauth_token_provider, url missing]
kafka_consumer.tests.test_unit ‑ test_oauth_config[No sasl_oauth_token_provider]
kafka_consumer.tests.test_unit ‑ test_oauth_config[client_id missing]
kafka_consumer.tests.test_unit ‑ test_oauth_config[client_secret missing]
kafka_consumer.tests.test_unit ‑ test_oauth_config[valid config]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy tls_ca_cert param]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy tls_cert param]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy tls_private_key param]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy tls_private_key_password param]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy validate_hostname param false]
kafka_consumer.tests.test_unit ‑ test_tls_config_legacy[legacy validate_hostname param true]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[Both false]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[Both true]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[only tls_validate_hostname_value false]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[only tls_validate_hostname_value true]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[tls_validate_hostname false as string]
kafka_consumer.tests.test_unit ‑ test_tls_validate_hostname_conflict[tls_validate_hostname true as string]
kafka_consumer.tests.test_unit ‑ test_tls_verify_is_string[given False tls_verify and other TLS options none, expect string false]
kafka_consumer.tests.test_unit ‑ test_tls_verify_is_string[given False tls_verify but TLS password, expect string true]
kafka_consumer.tests.test_unit ‑ test_tls_verify_is_string[given True tls_verify, expect string true]
kafka_consumer.tests.test_unit ‑ test_tls_verify_is_string[given empty tls_verify, expect default string true]
kafka_consumer.tests.test_unit ‑ test_when_consumer_lag_less_than_zero_then_emit_event
kafka_consumer.tests.test_unit ‑ test_when_consumer_metric_count_hit_context_limit_then_no_more_consumer_metrics
kafka_consumer.tests.test_unit ‑ test_when_highwater_metric_count_hit_context_limit_then_no_more_highwater_metrics
kafka_consumer.tests.test_unit ‑ test_when_partition_is_none_then_emit_warning_log
kafka_consumer.tests.test_unit ‑ test_when_partition_not_in_partitions_then_emit_warning_log
Loading