Confluent Parallel Consumer Core 0.5.2.2 API