Enterprise Messaging mit Apache Pulsar

Aufgabenstellung

Ein Unternehmen mit komplexer IT-Landschaft stand vor der Herausforderung, eine bestehende Messaging-Infrastruktur auf Basis von Tibco Rendezvous, Kafka und ArtemisJMS zu konsolidieren und zukunftssicher neu auszurichten. Die neue Lösung sollte geo-redundant, hochverfügbar und skalierbar sein – bei klaren Governance-Vorgaben und strikten Betriebsanforderungen. Gleichzeitig war entscheidend, dass die Architektur offen und erweiterbar bleibt, um zukünftige Integrationen wie IoT-Streams, ERP-Anbindungen oder KI-basierte Auswertungen flexibel zu ermöglichen.

Lösungsansatz

Im Rahmen des Projekts wurde eine Enterprise-Messaging-Architektur auf Basis von Apache Pulsar konzipiert und implementiert. Die Lösung folgt einem mehrschichtigen Aufbau und kombiniert Betriebssicherheit, Automatisierung und Governance:

• Cluster-Design & Geo-Redundanz: Aufbau und Absicherung mehrerer Standorte mit automatischem Failover und definierten Wiederanlaufstrategien.
• Protokollintegration: Unterstützung von Pulsar-Native, Kafka-Interop, MQTT und AMQP für größtmögliche Flexibilität in der Anwendungsintegration.
• Governance & Security: Multi-Tenant-Strukturen, Namensräume, rollenbasierte Authentifizierung und Ende-zu-Ende-Verschlüsselung.
• Deployment & Automatisierung: Entwicklung eigener Ansible-Module für das deklarative Management von Pulsar-Objekten (Tenants, Namespaces, Policies, Permissions) – inklusive versionskontrollierter, reproduzierbarer Konfigurationen.
• Evaluation von Enterprise Offerings: Technische Bewertung verschiedener kommerzieller Pulsar-Distributionen unter dem Aspekt digitaler Souveränität und Vendor-Unabhängigkeit. Dabei wurde auch die Reproduzierbarkeit von Builds bis auf Source-Code-Ebene analysiert, um taktische Handlungsfähigkeit bei sicherheitskritischen Ereignissen sicherzustellen.
• Tooling & Erweiterungen: Entwicklung von Health-Checks, Datenpumpen, Self-Fencing-Agents und automatisierten Load-Tests.
• Monitoring & Observability: Integration in bestehende Grafana/Prometheus-Stacks zur durchgängigen Überwachung und Messbarkeit der Systemgesundheit.

Die Architektur ist auf Langfristigkeit und Transparenz ausgelegt – sie bleibt beherrschbar, dokumentiert und nachvollziehbar, anstatt sich in komplexen Cloud-Abhängigkeiten zu verlieren.

Steckbrief

• Branche: Industriebetrieb
• Zeitraum: 2024–2025
• Technologien
  • Apache Pulsar
  • Golang (Custom Tools & Datenpumpen)
  • Kubernetes / Bare Metal
  • Prometheus / Grafana Stack
  • Ansible (eigene Module für Pulsar-Objekte)
  • TLS, JWT, RBAC

Die Lösung sorgt für stabile, hochperformante Datenströme und dient als zentrale Integrationsschicht für geschäftskritische Systeme und Produktionsprozesse. Sie verbindet Messaging, IoT-Integration und Governance zu einer nachhaltigen, souveränen Kommunikationsplattform, die als internes Referenzmodell für zukünftige Projekte genutzt wird.