Olá meu pessoal bom de papo, tudo bão?😁 Vim aqui com um script que aprendi para poder fazer um trabalho da faculdade usando Kafka e Python, quem sabe faço outro artigo mostrando como conectei e criei os consumers e producers usando Python.
Bem é um script com intuito de ser simples, pois a maioria dos que eu vi eram um pouco complicados e com outras ferramentas das quais eu não necessitava.
Na versão final só deixei o Zookeeper usado no kafka para fazer com que tudo trabalhe em conjunto de forma correta, o Kafka em si, e uma dash para ver melhor o que está acontecendo (isso ajuda muito) sendo possível de acessar pelo navegador no endereço localhost:8080
Script 📑
version: '3'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
ports:
- 2181:2181
kafka:
image: confluentinc/cp-kafka:latest
depends_on:
- zookeeper
ports:
- 29092:29092
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
kafka-ui:
image: provectuslabs/kafka-ui
container_name: kafka-ui
ports:
- "8080:8080"
restart: always
environment:
- KAFKA_CLUSTERS_0_NAME=local
- KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=kafka:9092
- KAFKA_CLUSTERS_0_ZOOKEEPER=zookeeper:2181
Algumas observações❗
O kafka está exposto na porta 29092 então quando for conectar coloque para conectar nesta porta em localhost.
Se for fazer alguma mudança cheque se as conexões entre os serviços estão funcionando, por exemplo, se mudar a porta do kafka será necessário alterar tanto no kafka-ui quanto no zookeeper
E por hoje é só pessoal! tchau 👋
Top comments (2)
Me ajudou bastante! 👏 👏
Vlww mano 😆