Messaging Engineer

We are seeking a Messaging Engineer to design, implement, and maintain the messaging infrastructure that enables real-time data exchange between factory automation systems, the MES (Manufacturing Execution System), and enterprise IT platforms. Key Responsibilities : Design, implement, and maintain messaging infrastructure supporting real-time data exchange between shop-floor systems, MES, and enterprise IT platforms. Deploy and manage distributed message brokers (Apache Kafka clusters or MQTT-based systems) to enable streaming communication from shop-floor equipment and sensors to cloud/data center applications. Define and govern message topics/channels and data schemas to ensure consistent structure for all events (e.g., equipment status updates, test results, alarm signals). Optimize messaging systems for low latency and high reliability, ensuring critical events propagate instantly without loss or duplication. Implement monitoring and alerting for the messaging pipeline — tracking throughput, lag, and error rates — and troubleshoot issues in message flow health. Collaborate with development teams to integrate applications with the messaging layer, and tune producer/consumer performance to meet factory throughput demands. Required Skills : Strong expertise in message-oriented middleware and streaming platforms. Hands-on experience deploying/managing Apache Kafka (preferred) or similar technologies (RabbitMQ, IBM MQ, Apache Pulsar) in production — including topic design, partitioning, replication, and broker configuration. Proficiency in designing real-time data pipelines with pub/sub patterns, ensuring high throughput and fault tolerance (e.g., Kafka Connect or MQTT clients). Solid programming skills in Java/Scala or Python for developing and optimizing producers/consumers. Familiarity with messaging system internals (broker clustering, retention policies, consumer groups, offset management). Preferred Skills : Experience with messaging in industrial/IoT contexts (MQTT, AMQP protocols) for collecting data from PLCs or IoT sensors. Knowledge of data serialization formats and schema management (Avro, Protocol Buffers, Schema Registry). Proficiency in monitoring tools for streaming systems (Prometheus, Grafana) and setting up alerts/dashboards. Familiarity with integration patterns (enterprise service bus, event-driven microservices) and understanding of MES/database/analytics integration.