dipinhora
commented
6 years ago - remove use of case functions for ponyc master compatibility
- randomize order in which topics/partitions are added to fetch request to prevent starvation due to how kafka brokers repond to fetch requests
- replace I32 and other similar types with nicer type aliases
- send list of throttled topic/partitions to producers to simplify interface
- add KafkaClient to all public traits in case a single actor is interacting with multiple client instances
- use KafkaBrokerConnection instead of KafkaNodeId in partition mapping
- Bug fixes related to start offsets and partial messages
- Add space to help message for cli parser
- backport of ponylang/ponyc/#1904 with fix to ponylang/ponyc#2620 for an edge case around the apply_backpressure logic