Кафка, производящая и потребляющая в Python, не работает. Кафка в Docker и создание Totopics работает ⇐ Python

[Anonymous]

Попытка взять кафку в Docker на MacBook. (См. Сценарий Python ниже) Просто ничего не происходит, и нечего видеть в журналах докеров < /li>
< /ul>
библиотеки, используемые < /h3>
Следующие библиотеки Python используются в сценариях Python: < /p>

/>[*]pybind11==2.13.6
< /ul>
docker compose file < /h3>
Docker-compose.yml взят из apache /kafka на докером. 9092. < /P>
services:
broker:
image: apache/kafka:latest
container_name: kafka
volumes:
- ./data:/tmp/kraft-combined-logs:rw
ports:
- '9092:9092'
environment:
KAFKA_NODE_ID: 1
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT'
KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT_HOST://localhost:9092,PLAINTEXT://broker:19092'
KAFKA_PROCESS_ROLES: 'broker,controller'
KAFKA_CONTROLLER_QUORUM_VOTERS: '1@broker:29093'
KAFKA_LISTENERS: 'CONTROLLER://:29093,PLAINTEXT_HOST://:9092,PLAINTEXT://:19092'
KAFKA_INTER_BROKER_LISTENER_NAME: 'PLAINTEXT'
KAFKA_CONTROLLER_LISTENER_NAMES: 'CONTROLLER'
CLUSTER_ID: 'sdfgvkdmpritgnvsyr56'
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
KAFKA_SHARE_COORDINATOR_STATE_TOPIC_REPLICATION_FACTOR: 1
KAFKA_SHARE_COORDINATOR_STATE_TOPIC_MIN_ISR: 1
KAFKA_LOG_DIRS: '/tmp/kraft-combined-logs'
< /code>
Кафка запускается и работает без каких-либо ошибок. < /p>
Создание темы < /h3>
from kafka import KafkaAdminClient
from kafka.admin import NewTopic, ConfigResource, ConfigResourceType
from kafka.errors import TopicAlreadyExistsError

if __name__ == '__main__':
admin_client = KafkaAdminClient(bootstrap_servers='localhost:9092')

# Create a Topic
topic_list = []
new_topic = NewTopic(name="bankbranch", num_partitions=2, replication_factor=1)
topic_list.append(new_topic)

try:
admin_client.create_topics(new_topics=topic_list)
except TopicAlreadyExistsError:
print('*** Topic already exists: bankbranch')

< /code>
См. Темы < /h3>
Внутри контейнера Docker < /p>
9f30328dd248:/opt/kafka/bin$ ./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic
Created topic test-topic.

9f30328dd248:/opt/kafka/bin$ ./kafka-topics.sh --bootstrap-server localhost:9092 --list
bankbranch
test-topic
< /code>
Итак, работает сценарий Create-Topic.from kafka import KafkaProducer
import json

if __name__ == '__main__':
producer = KafkaProducer(
bootstrap_servers='localhost:9092',
value_serializer=lambda v: json.dumps(v).encode('utf-8')
)

producer.send("bankbranch", {'atmid': 1, 'transid': 100})
producer.send("bankbranch", {'atmid': 2, 'transid': 101})
< /code>
Kafka-consumer.py
from kafka import KafkaConsumer

if __name__ == '__main__':
consumer = KafkaConsumer('bankbranch',
bootstrap_servers='localhost:9092',
auto_offset_reset='latest',
)
for msg in consumer:
print(msg.value.decode("utf-8"))

< /code>
Производитель тестирования EN Consumer < /h3>
Я начинаю как на хосте, так и без ответа. Нет ошибок, просто ничего.>

Подробнее здесь: https://stackoverflow.com/questions/796 ... r-and-crea