Status

Current state: Under Discussion

Discussion thread: here

JIRA: here 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

Headers are useful for tracking many aspects of the performance testing. Like regions, hosts, downstream consumer flags, etc...

Public Interfaces

• org.apache.kafka.tools.ProducerPerformance

Proposed Changes

Add ability to pass headers to the produced requests by adding a --headers arg, --headers-file  arg, or both.

Compatibility, Deprecation, and Migration Plan

• None. This should be a fully backward compatible change that does not require any additional work on existing users part.

Test Plan

Running a perf test with --headers and verifying that headers are persisted in kafka.

Rejected Alternatives

If there are alternative ways of accomplishing the same thing, what were they? The purpose of this section is to motivate why the design is the way it is and not some other way.