python (65.1k questions)

javascript (44.2k questions)

reactjs (22.7k questions)

java (20.8k questions)

c# (17.4k questions)

html (16.3k questions)

r (13.7k questions)

android (12.9k questions)

Questions - broker

Why do I get Intermittent "NoBrokersAvailable" errors, with python application (kafka-python Producer)?

I’m trying to make a connection to Kafka on AWS. Communication is done over TLS.<br> Kafka-python==2.0.2 is used, and the KafkaProducer configuration is as follows: From Kafka import KafkaProduc...
test-img

bowoojang

python

apache-kafka

kafka-producer-api

kafka-python

broker

Votes: 0

Answers: 2

Latest Answer

In my case, I specified the kafka version while creating the Producer instance and I don't see the NoBrokersAvailable Errors anymore. producer = KafkaProducer(bootstrap_servers='localhost:9092', ...
test-img

Gaurav Singla

Mosquitto Broker - Can still sign in with no credentials after allow_anonymous set to false

Following Steve Copes "How to install the Mosquitto Broker on Windows", I created a password.txt file and encrypted it using the mosquiito_passwd utility. Then I edited the mosquitto.conf f...
test-img

Tom Hughes

windows

authentication

mqtt

mosquitto

broker

Votes: 0

Answers: 1

Latest Answer

Solution Found: Adding 'listener 1883' before allow_anonymous false has got it working although I am unsure why that makes a difference. Config file as follows: # acl_file listener 1883 allow_anonymou...
test-img

Tom Hughes

How to connect to open source emqx broker and build his own broker?

Protocol: mqtt Version: 3.1.1 Gateway model: CloudGate Ethernet CG0102 I'm publishing json message from my gateway which is connected to an open source Emqx broker (broker.emqx.io) port 1883 for a tes...
test-img

Thib

mqtt

broker

emqx

Votes: 0

Answers: 1

Latest Answer

Client_ID needs to be unique for every client, so you can not reuse Client_ID between clients. The MQTT spec says that the broker should kick the oldest client off when a new client connects with the ...
test-img

hardillb

How can I publish custom broker messages in minos?

I want to send a message to notify about something in one of my microservices, but I don't want to do that through a domain event, which requires to create, update or delete one of the entities of the...
test-img

garciparedes

python

microservices

broker

minos

Votes: 0

Answers: 1

Latest Answer

Yes! You can do that directly using the BrokerPublisher instance injected in the corresponding service. If you want to send a message you can do as follows: from minos.common import ModelType from min...
test-img

garciparedes

Posts

Questions

Blogs

Jobs