我在一个Google云平台集群中成功地连接了一个Kafka生产商和一个消费者:$ bin/kafka-console-producer.sh config/server.properties[cluster-id].internal:9092 --topic test \现在,我想使用以下python脚本向Kafka生产者服务器发送消息:
from kafka因此,我开始想知道如何通过GCP集群的外部(静态) I
我正在尝试用python编写一个生产者和消费者代码,使用pika for rabbitmq。然而,对于我的特定情况,我需要在另一台主机上运行生产者,在另一台主机上运行消费者。import pika
parameters = pika.ConnectionParameters('ip add of another host', 5672, '/', credentials)
c