The integration tests for the producer are in with the server since the
dependency is that the server depends on the clients rather than vice
versa). Only the mock tests are with the clients. You should be able to add
to one of the tests in
core/src/test/scala/integration/kafka/api/Producer*
On
I have been looking at some unassigned JIRAs to work on during some
spare time and found this one
https://issues.apache.org/jira/browse/KAFKA-1837. As I note in that
JIRA, I can see why this happens and have a potential fix for it. But to
first reproduce the issue and then verify the fix, I hav
I have been looking at some unassigned JIRAs to work on during some
spare time and found this one
https://issues.apache.org/jira/browse/KAFKA-1837. As I note in that
JIRA, I can see why this happens and have a potential fix for it. But to
first reproduce the issue and then verify the fix, I hav
