Projects

 Open-source

 Apache Kafka

https://github.com/apache/kafka

Main contributions:

• Author of the following improvement proposals (KIP):
  • KIP-122: https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+tooling (Adopted)
  • KIP-171: https://cwiki.apache.org/confluence/display/KAFKA/KIP-171+-+Extend+Consumer+Group+Reset+Offset+for+Stream+Application (Adopted)
  • KIP-244: https://cwiki.apache.org/confluence/display/KAFKA/KIP-244%3A+Add+Record+Header+support+to+Kafka+Streams+Processor+API (Adopted)
  • KIP-634: https://cwiki.apache.org/confluence/display/KAFKA/KIP-634%3A+Complementary+support+for+headers+and+record+metadata+in+Kafka+Streams+DSL (Discarded)
  • KIP-666: https://cwiki.apache.org/confluence/display/KAFKA/KIP-666%3A+Add+Instant-based+methods+to+ReadOnlySessionStore (Adopted)
  • KIP-667: https://cwiki.apache.org/confluence/display/KAFKA/KIP-667%3A+Remove+deprecated+methods+from+ReadOnlyWindowStore (Adopted)
  • KIP-820: https://cwiki.apache.org/confluence/display/KAFKA/KIP-820%3A+Extend+KStream+process+with+new+Processor+API (Adopted)
  • KIP-821: https://cwiki.apache.org/confluence/display/KAFKA/KIP-821%3A+Connect+Transforms+support+for+nested+structures (Voting in progress)
• Helped with the implementation of:
  • KIP-478:
    • https://cwiki.apache.org/confluence/display/KAFKA/KIP-478+-+Strongly+typed+Processor+API
    • https://issues.apache.org/jira/browse/KAFKA-8410

Proof-of-concepts:

• Kafka CLIs: https://github.com/jeqo/kafka-cli
• Other minor PoCs: https://github.com/jeqo/poc-apache-kafka/

 Zipkin

https://github.com/openzipkin/zipkin

Main contributions:

• Zipkin storage based on Kafka Streams: https://github.com/openzipkin-contrib/zipkin-storage-kafka
• Brave support for Kafka clients and streams: https://github.com/openzipkin/brave
• Maintaining Zipkin usage of Kafka as collector: https://github.com/openzipkin/zipkin-reporter-java
• Kafka interceptors for Zipkin tracing: https://github.com/openzipkin-contrib/brave-kafka-interceptor

 Other contributions

 Micrometer

• Kafka Clients instrumentation for Metrics: https://github.com/micrometer-metrics/micrometer/pull/1835

 Open Politica

https://github.com/openpolitica

Helped with:

• Collecting data from public institutions
  • https://github.com/openpolitica/jne-elecciones/
  • https://github.com/openpolitica/congreso-proyecto-ley
• Design the collection of Peruvian Congress votes:
  • https://github.com/openpolitica/congreso-pleno-asistencia-votacion/
  • https://github.com/openpolitica/congreso-pleno