GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/110
KAFKA-2071: Replace Producer Request/Response with their org.apache.kafka.common.requests equivalents This PR replaces all producer request/response with their common equivalents but doesn't touch old producer at all. Some conversions are made in KafkaApis to convert Java type/record to their Scala equivalents. For instance, `TopicPartition` must be converted to `TopicAndPartition` when it is passed to the ReplicaManager and vice versa. I've decided to not touch internals right now as their are used by other parts which makes updating them difficult. I'd prefer to address internals in a separate JIRA once all requests and responses are updated. You can merge this pull request into a Git repository by running: $ git pull https://github.com/dajac/kafka KAFKA-2071 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/110.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #110 ---- commit 8e1ca3c817b768a399d5ea54d6360d6180e4c39a Author: David Jacot <david.ja...@swisscom.com> Date: 2015-08-04T16:47:36Z Replace Producer Request/Response with their org.apache.kafka.common.requests equivalents. ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---