testcontainers / testcontainers/testcontainers-python
Bug: KafkaContainer.tc_start not starting when using a Network
Abierto
Nadie ha tomado este issue todavía.
- Lenguaje dominante
- Python
- Estrellas
- 2.3k
- Forks
- 386
- Merge medio
- 4 h 40 min
- PR fusionados (30 d)
- 1
Descripción
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)
Guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Línea de trabajo
Empieza en KafkaContainer.tc_start y compara sus supuestos sobre la red del host con la configuración de Network mostrada en el issue. Traza cómo interactúan _get_network_alias, get_bootstrap_server y el script de inicio del contenedor. El trabajo estará terminado cuando KafkaContainer se inicie correctamente en un Network y get_bootstrap_server devuelva un bootstrap server utilizable.
Escrito por el modelo de indexación a partir del texto del issue.
Evaluación
- Stack tecnológico
- docker, kafka, python
- Área
- distributed-systems, networking
- Tipo de issue
- Error
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Estado de actividad
- Estancado
- Claridad
- Bastante claro
- Aptitud para principiantes
- 42/100