Questions tagged [broker]
389 questions
171
votes
13 answers
Is Zookeeper a must for Kafka?
In Kafka, I would like to use only a single broker, single topic and a single partition having one producer and multiple consumers (each consumer getting its own copy of data from the broker). Given this, I do not want the overhead of using…

Paaji
- 2,139
- 4
- 14
- 11
33
votes
1 answer
Broker architectural pattern in plain english
Could someone explain the Broker pattern to me in plain english? Possibly in terms of Java or a real life analogy.

habitats
- 2,203
- 2
- 23
- 31
26
votes
3 answers
In RabbitMQ which is more expensive, multiple queues per exchange, or multiple exchanges and less queues per each?
So we decided to go with RabbitMQ as a message/event bus in our migration to micro-services architecture, but we couldn't find a definite answer on what is the best way of putting our queues, we have two options to go with:
One main exchange which…

bingorabbit
- 665
- 5
- 11
17
votes
1 answer
Horizontally scaling mosquitto broker
I am considering mosquitto for a MQTT broker. From what I've read, I realized that Mosquitto doesn't support Horizontal Scaling.
So far all other criteria of my requirements can be met with Mosquitto.
I'm not sure if the question is too generic or…

Dhanushka Dolapihilla
- 1,115
- 3
- 17
- 34
16
votes
2 answers
How does Celery work?
I have recently started working on distributed computing for increasing the computation speed. I opted for Celery. However, I am not very familiar with some terms. So, I have several related questions.
From the Celery docs:
What's a Task…

jeldikk
- 353
- 2
- 12
15
votes
3 answers
Spring boot Artemis embedded broker behaviour
Morning all,
I've been struggling lately with the spring-boot-artemis-starter.
My understanding of its spring-boot support was the following:
set spring.artemis.mode=embedded and, like tomcat, spring-boot will instanciate a broker reachable through…

louis gueye
- 215
- 1
- 2
- 8
13
votes
2 answers
WARNING as java.io.EOFException when ActiveMQ starts
I am trying to start the ActiveMQ 5.11 and I see a WARNING as below:
WARN | Transport Connection to: tcp://127.0.0.1:40890 failed: java.io.EOFException
My activemq.xml is as below:

divinedragon
- 5,105
- 13
- 50
- 97
11
votes
2 answers
ThingWorx Horizontal Scalability
What architecture and application development best practices must be followed in order to scale a TWX application?
The majority of applications start with few devices but with time they quickly build up to thousands of devices. Once the amount of…

Mgccon
- 425
- 3
- 11
10
votes
2 answers
Keycloak: How to login only through identity provider
I have an Keycloak Broker and 2 Identity Providers running. Currently I saw the Username and Password fields and the 2 links to the configured Identity Providers at the broker login screen. The login through Identity Providers is possible after…

hb70muc
- 101
- 1
- 1
- 5
9
votes
4 answers
Broker Problem with connect to Mac from Visual Studio 2019 Xamarin.iOS
After updated mac OS to Catalina 10.15.4 and XCode 11.4 and VS 2019 16.5.1
I can't pairing to mac from VS, there is getting the error in VS:
"An error occurred while trying to start Broker ...".
Info at log file:
"Broker could not be…

Polyariz
- 534
- 1
- 7
- 17
9
votes
4 answers
What is a partition leader in Apache Kafka?
Are kafka leaders partitions themselves or are they brokers?
My initial understanding was that they were partitions which acted as read/write agents which then deffered their value to ISRs.
However recently I have been hearing them mentioned as…

Matt
- 113
- 1
- 1
- 5
9
votes
1 answer
What is the clientID needed for?
Since specifying the clienID is only a feature in the class MqttAndroidClient, and can not be specified when using classes IMqttClient and IMqttAsynchClient.
what is the real purpose of connecting a client with a unique ID?

rmaik
- 1,076
- 3
- 15
- 48
8
votes
4 answers
Automating Etrade
Hey everyone, I was wondering how would I start programming an interface to trading stocks in Etrade in python. I am attempting to make an automated trading bot, but there is no api publicly available for automated trading with Etrade. Thanks in…

iAlexTsang
- 189
- 2
- 10
7
votes
1 answer
Celery Tasks Not Being Processed
I'm trying to process some tasks using celery, and I'm not having too much luck. I'm running celeryd and celerybeat as daemons. I have a tasks.py file that look like this with a simple app and task defined:
from celery import Celery
app =…

Nat Dempkowski
- 2,331
- 1
- 19
- 36
7
votes
2 answers
Middleware in client/server communication
I'm building a client/server pair in C++, and I've used the winsock for the communication. However, I'm not able to find any library in C++ by which I can implement something that, instead of sending requests directly from the client to the server,…

networks
- 115
- 2
- 8