You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/03/14 11:03:01 UTC
[jira] [Commented] (KAFKA-8102) Trogdor - Add Produce workload
transaction generator by interval
[ https://issues.apache.org/jira/browse/KAFKA-8102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792556#comment-16792556 ]
ASF GitHub Bot commented on KAFKA-8102:
---------------------------------------
stanislavkozlovski commented on pull request #6444: KAFKA-8102: Add an interval-based Trogdor transaction generator
URL: https://github.com/apache/kafka/pull/6444
This patch adds a TimeIntervalTransactionsGenerator class which enables the Trogdor ProduceBench worker to commit transactions based on a configurable millisecond time interval.
It also improves the Coordnator client's handling of a 409 response on CreateTask
Worth saying I tested these changes manually
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> Trogdor - Add Produce workload transaction generator by interval
> ----------------------------------------------------------------
>
> Key: KAFKA-8102
> URL: https://issues.apache.org/jira/browse/KAFKA-8102
> Project: Kafka
> Issue Type: Improvement
> Reporter: Stanislav Kozlovski
> Assignee: Stanislav Kozlovski
> Priority: Major
>
> Trogdor's specification for produce worker workloads ([ProduceBenchSpec|https://github.com/apache/kafka/blob/trunk/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java]) supports configuring a transactional producer using a class that implements `TransactionGenerator` interface.
> [UniformTransactioGenerator|https://github.com/apache/kafka/blob/trunk/tools/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java] which triggers a transaction every N records.
> It would be useful to have a generator which supports triggering a transaction in an interval - e.g every 100 milliseconds. This is how Kafka Streams configures its own [EOS semantics by default|https://github.com/apache/kafka/blob/8e975400711b0ea64bf4a00c8c551e448ab48416/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L140].
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)