Skip to content

mqtt-kafka does not limit client sharding to mqtt v5 #708

@jfallows

Description

@jfallows

Describe the bug
When serverRef is specified in mqtt-kafka, this allows the mqtt-kafka binding to make use of kafka topic sharding and redirect clients to their zilla instance affinity, but mqtt v5 introduced the redirect capability so mqtt v3.1.1 clients cannot follow the redirect.

To Reproduce
Steps to reproduce the behavior:

  1. Use mqtt.kafka.broker in zilla-examples with multiple Zilla instances
  2. Ensure mqtt-sessions topic has multiple partitions
  3. Update zilla.yaml to specify serverRef in mqtt-kafka binding
  4. Connect with mqtt v3.1.1 client
  5. See error when not on affinity Zilla instance for client id

Expected behavior
When both mqtt v3.1.1 and mqtt v5 are supported, kafka topic sharding should be disabled.

Screenshots
None

Desktop (please complete the following information):
N/A

Smartphone (please complete the following information):
N/A

Additional context
None

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions