testcontainers / testcontainers/testcontainers-python
Bug: KafkaContainer.tc_start not starting when using a Network
Đang mở
Chưa có ai nhận issue này.
- Ngôn ngữ chính
- Python
- Star
- 2.3k
- Fork
- 386
- Merge trung bình
- 4 giờ 40 phút
- Pull request đã merge (30 ngày)
- 1
Mô tả
If fails to start, since tc_start assumes that the container is using host networking
from docker.types import EndpointConfig
from testcontainers.core.container import DockerContainer
from testcontainers.core.network import Network
from testcontainers.kafka import KafkaContainer
def _connect_to_network(ctr: DockerContainer, network: Network, alias: str):
# Needed until https://github.com/testcontainers/testcontainers-python/issues/645 is fixed
ctr.with_kwargs(
network=network.name, networking_config={network.name: EndpointConfig("1.33", aliases=[alias])}
)
with Network() as network:
ctr = KafkaContainer(image=f"confluentinc/cp-kafka:{KAFKA_VERSION}")
_connect_to_network(ctr, network, "kafka")
with ctr:
assert ctr.get_bootstrap_server(). # This should start
A possible fix:
def tc_start(self):
# We replace these three lines, which assume host networking
# host = self.get_container_host_ip()
# port = self.get_exposed_port(self.port)
# listeners = f"PLAINTEXT://{host}:{port},BROKER://$(hostname -i | cut -d' ' -f1):9092"
listeners = f"PLAINTEXT://{self._get_network_alias()}:{self.port},BROKER://$(hostname -i | cut -d' ' -f1):9092"
data = (
dedent(
f"""
#!/bin/bash
{self.boot_command}
export KAFKA_ADVERTISED_LISTENERS={listeners}
. /etc/confluent/docker/bash-config
/etc/confluent/docker/configure
/etc/confluent/docker/launch
"""
)
.strip()
.encode("utf-8")
)
self.create_file(data, KafkaContainer.TC_START_SCRIPT)
Hướng dẫn đóng góp
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Hướng nghiên cứu
Bắt đầu từ KafkaContainer.tc_start và so sánh các giả định về mạng host của nó với thiết lập Network được nêu trong issue. Theo dõi cách _get_network_alias, get_bootstrap_server và script khởi động container tương tác với nhau. Hoàn thành khi KafkaContainer khởi động thành công trên một Network và get_bootstrap_server trả về một bootstrap server có thể sử dụng.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Đánh giá
- Công nghệ
- docker, kafka, python
- Lĩnh vực
- distributed-systems, networking
- Loại issue
- Lỗi
- Độ khó
- 3/5
- Thời gian dự kiến
- 1-2 ngày
- Mức độ hoạt động
- Đình trệ
- Độ rõ ràng
- Khá rõ ràng
- Mức phù hợp với người mới
- 42/100