test/test_cluster

dpkp · dpkp · commit 62da7fade868 · 2026-03-22T21:41:46.000-07:00
diff --git a/test/test_cluster.py b/test/test_cluster.py
@@ -3,7 +3,7 @@
 import socket
 
 from kafka.cluster import ClusterMetadata, collect_hosts
-from kafka.protocol.metadata import MetadataResponse
+from kafka.protocol.new.metadata import MetadataResponse
 
 
 def test_empty_broker_list():
