1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
# pylint: skip-file
from __future__ import absolute_import
import pytest
from kafka.cluster import ClusterMetadata
from kafka.protocol.metadata import MetadataResponse
def test_empty_broker_list():
cluster = ClusterMetadata()
assert len(cluster.brokers()) == 0
cluster.update_metadata(MetadataResponse[0](
[(0, 'foo', 12), (1, 'bar', 34)], []))
assert len(cluster.brokers()) == 2
# empty broker list response should be ignored
cluster.update_metadata(MetadataResponse[0](
[], # empty brokers
[(17, 'foo', []), (17, 'bar', [])])) # topics w/ error
assert len(cluster.brokers()) == 2
|
