b1ackd0t

The `LeaderNotAvailable` is retriable according to [this](https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol) docs. A possible workaround would be to retry and if not possibly fail and manage the fails. The [library](https://github.com/segmentio/kafka-go) we are using retries...

> Can you point out the exact section for this? You can check it from [here](https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol/#AGuideToTheKafkaProtocol-ErrorCodes) > Please investigate if it works like Yes it works like that. I have...

## Topic management Kafka topics are the categories used to organize messages. Each topic has a name that is unique across the entire Kafka cluster. ### Creation - We are...

The whole team @nakujaproject is willing to help.

Yes. No problem

pip install imutils

This should probably be changes to `opentelemetry` as we currently move from `opentracing` to `opentelemetry`. This is the specification for opentelemetry - https://github.com/open-telemetry/opentelemetry-specification/

[From](https://github.com/segmentio/kafka-go/issues/283) this it appears that in the segmentio library you can list all topics with a bit of work around. But the problem is when the MQTT forwarder is subscribing...

Regarding Kafka support for wildcard, I have tested using [confluent-kafka-python](https://github.com/confluentinc/confluent-kafka-python) and it supports. I think [the issue is the library we are using](https://github.com/segmentio/kafka-go/pull/663#issuecomment-980583030) I have tried to pass in a...

Hi there! I am interested in contributing to this project and would like to request permission to work on this issue. I have experience with the technologies involved and believe...