Repository: kafka Updated Branches: refs/heads/0.11.0 8265d1a40 -> ce2567fb8
MINOR: explain producer naming within Streams Author: Matthias J. Sax <[email protected]> Reviewers: Damian Guy <[email protected]> Closes #3401 from mjsax/minor-producer-naming-011 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ce2567fb Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ce2567fb Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ce2567fb Branch: refs/heads/0.11.0 Commit: ce2567fb8047255e9d9abe65bac9b26c6f967f7a Parents: 8265d1a Author: Matthias J. Sax <[email protected]> Authored: Thu Jun 22 08:21:32 2017 +0100 Committer: Damian Guy <[email protected]> Committed: Thu Jun 22 08:21:32 2017 +0100 ---------------------------------------------------------------------- docs/streams.html | 13 +++++++++++++ 1 file changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ce2567fb/docs/streams.html ---------------------------------------------------------------------- diff --git a/docs/streams.html b/docs/streams.html index 1f1adb1..625736e 100644 --- a/docs/streams.html +++ b/docs/streams.html @@ -925,6 +925,19 @@ $ java -cp path-to-app-fatjar.jar com.example.MyStreamsApp If you want to view the changelog stream of the <code>KTable</code> then you could call <code>KTable.toStream().print()</code>. </p> + <p> Metrics using exactly-once semantics: </p> + <p> + If exactly-once processing is enabled via the <code>processing.guarantees</code> parameter, internally Streams switches from a producer per thread to a producer per task runtime model. + In order to distinguish the different producers, the producer's <code>client.id</code> additionally encodes the task-ID for this case. + Because the producer's <code>client.id</code> is used to report JMX metrics, it might be required to update tools that receive those metrics. + </p> + <p> Producer's <code>client.id</code> naming schema: </p> + <ul> + <li> at-least-once (default): <code>[client.Id]-StreamThread-[sequence-number]</code> </li> + <li> exactly-once: <code>[client.Id]-StreamThread-[sequence-number]-[taskId]</code> </li> + </ul> + <p> <code>[client.Id]</code> is either set via Streams configuration parameter <code>client.id<code> or defaults to <code>[application.id]-[processId]</code> (<code>[processId]</code> is a random UUID). </p> + <h3><a id="streams_api_changes_01021" href="#streams_api_changes_01021">Notable changes in 0.10.2.1</a></h3> <p>
