Alternatives to Kafka¶
This page documents constraints when integrating Waterstream with systems that expose Kafka-compatible APIs but are not Apache Kafka (for example, Redpanda or Azure Event Hubs).
Azure Event Hubs¶
Azure Event Hubs provides Kafka protocol compatibility, but not full parity with Apache Kafka. The limitations below focus on Waterstream operational behavior.
Microsoft references used for this section:
Note
Azure quotas and preview feature availability can change. Validate current limits before production rollout.
Known limitations and Waterstream workarounds¶
Limitation |
Waterstream impact |
Recommended workaround/configuration |
Tier mitigation |
|---|---|---|---|
No message compression support on Event Hubs Kafka endpoint |
Higher network and storage consumption when Waterstream publishes high-volume MQTT traffic. |
Set |
None. Not mitigated by Standard, Premium, or Dedicated. |
No idempotent producer in non-transactional Event Hubs mode |
Retries can produce duplicates for at-least-once delivery paths. |
Set |
Use Premium or Dedicated with transaction-capable mode when strongest QoS 2 behavior is required. |
No Kafka transactions in Standard plan |
Strongest transaction-backed QoS 2 guarantees are not available. |
Keep |
Premium and Dedicated currently document transaction support as public preview. |
No log compaction |
Session and retained-message state topics rely on retention windows instead of compaction, so state can expire and require rebuild/recovery behavior after retention lapses. |
Tune time-based retention to exceed expected offline session windows. Document recovery implications (session rehydration and retained-message repopulation) in runbooks. |
None. Compaction is not enabled by tier. |
Topic count limits (Standard: 10 Event Hubs per namespace) |
Restricts multi-topic routing and environment isolation patterns. Waterstream required topics plus internal topics consume the quota quickly. |
Consolidate topic design, avoid unnecessary per-tenant/per-feature topic fan-out, and reserve capacity for internal topics. |
Premium and Dedicated provide higher limits. |
Consumer group limits (Standard: 20 per Event Hub) |
Limits parallel independent consumers and integration patterns built on multiple consumer groups. |
Reuse consumer groups where possible and plan group budgets per workload. |
Premium and Dedicated provide higher limits. |
Partition count limits |
Upper bound on throughput parallelism and scaling by partitioning. |
Size partition counts early, load-test realistic traffic, and scale up tier when partition ceilings are reached. |
Premium and Dedicated provide higher partition ceilings. |
Message size limit (1 MB) |
Large MQTT payloads can be rejected by Kafka endpoint writes. |
Keep payloads below 1 MB including protocol overhead. For larger payloads, publish pointers (for example, object storage URLs) instead of full payload bodies. |
None. Treat as a hard design constraint unless Microsoft updates limits. |
Kafka Streams internal topic overhead |
Internal changelog/repartition topics count toward Event Hub quotas, reducing available topic budget for user data. |
Include internal topics (for example,
|
Premium and Dedicated reduce pressure by offering larger quotas. |
Kafka API version/feature compatibility gaps vs Apache Kafka |
Some client API versions/features may be unsupported or partially supported, affecting advanced producer/consumer behaviors. |
Validate Waterstream/Kafka-client compatibility against Microsoft Kafka support docs before upgrades. Re-test connectivity and critical flows after broker/client version changes. |
Premium and Dedicated improve capacity-related limits, but API compatibility is endpoint-specific, not full Apache Kafka parity. |
Operational guidance¶
Always include Event Hubs quotas in capacity planning for both user topics and internal Waterstream topics.
For strict QoS 2 requirements, use Premium or Dedicated and validate current transaction support status.
Keep a regression checklist for Event Hubs API compatibility during Waterstream/Kafka client upgrades.