Repository: kafka Updated Branches: refs/heads/trunk 76f6e14b0 -> cae5977ed
MINOR: explain producer naming within Streams Author: Matthias J. Sax <[email protected]> Reviewers: Bill Bejeck <[email protected]>, Damian Guy <[email protected]> Closes #3378 from mjsax/minor-producer-naming Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cae5977e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cae5977e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/cae5977e Branch: refs/heads/trunk Commit: cae5977ed0d6b63f992973800273769c970b0a0a Parents: 76f6e14 Author: Matthias J. Sax <[email protected]> Authored: Wed Jun 21 09:32:46 2017 +0100 Committer: Damian Guy <[email protected]> Committed: Wed Jun 21 09:32:46 2017 +0100 ---------------------------------------------------------------------- docs/streams.html | 13 +++++++++++++ 1 file changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/cae5977e/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>
