Lead developer / SME for Kafka & RabbitMQ services for the team of 8 engineers providing messaging & caching solutions

Designed the deployment and operations processes allowing the team to provide reliable and performant Kafka and RMQ services.

Designed multiple upper-layer usecases' (e.g. query trickle, core database transactions, search ingester, distributed job framework) usage of Kafka & RMQ, and acting as a technology expert in the case of incidents.

Created Java-based client libraries providing company-specific functionalities over plain Kafka/RMQ such as service discovery, metrics, encryption, configuration resolution and its change at runtime. Provided large message support in Kafka (chunking or using an external store like Redis) and controlled failover (with MirrorMaker2 and custom client code for automatic partition switch).

Replaced existing file-driven client configuration by creating a configuration-resolution service contacted by the client libraries during the using service's bootstrap.

Improved Kafka/RMQ operations by creating sidecar services responsible for the management of the RMQ and Kafka installations: providing service discovery data, RMQ cluster health monitoring, Kafka dead topic detection, ensuring backend configuration via policies.

Prototyped a joint Kafka-and-RMQ client library allowing for faster end-to-end communication while providing Kafka persistence guarantees.

Currently working on increasing service visibility and decreasing operator pain by creating the services for service topology tracking and request tracing.

Tech: Java, Spring + Spring Boot, Kafka, RabbitMQ, Zookeeper, Redis, SQL (Hibernate), JUnit + Mockito, Gatling, Scala, Python, Gradle, git, Docker, Envoy proxy, Chef, Kubernetes, TeamCity, Jenkins

Designer, developer and code owner of Kafka support in Envoy proxy

Created protocol parser (by creating the generator script consuming Kafka protocol

spec), broker filter (for capturing metrics), mesh filter (to have Envoy act as a front proxy

for multiple Kafka clusters).

Lead developer / SME for the team of 7 engineers providing entitlement and onboarding services in UBS Neo platform

Designed and implemented mission-critical entitlements and onboarding services, providing highly performant read operations (permission checks), with multi-cluster replication of write data, and audit trail.

Implemented business-driven rules related to entitlement checks (2FA vs 1FA,

entitlement packages, geography-driven limitations).

Tech: Java, Spring, neo4j + Cypher, Zookeeper, REST, JMS (29West, Tibco EMS), SQL (Hibernate, MyBatis), JUnit + Mockito, Maven, TeamCity

Developer of Netezza monitoring application (nzhealthcheck)

Fixed multiple threading/shutdown issues by providing correct threading model and changing the architecture from one-threaded to lightweight 'handler' application with multiple child data collector processes. Fixed high memory usage by replacing boost::property_true with tinyxml.

Tech: C, C++, POSIX (pthreads), boost, Perl & Bash scripting, SQL (sqlite, nzsql)

Development lead for the team of 7 engineers providing AllShare SDK

Developed DLNA device simulators embedded in Eclipse, such as video/audio player or a multimedia source.

Created multicast- & subscription-proxying solution for DLNA, allowing Android DLNA application running inside the simulator to connect with the host network.

Created a Scala-based prototype of IDE for Cloud-based applications.

Released AllShare SDK 1.0 in 12/2012.

Tech: Java, DLNA, UPnP, Eclipse RCP, Scala, C++, boost, JUnit, git, Bamboo