[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116407#comment-17116407 ] tigertan commented on KAFKA-10043: -- Similar bugs exist in the class of kafka.tools.Cons

[jira] [Updated] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10043: - Attachment: bug-.png > Some parameters will be overwritten which was configured in consumer.config > w

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116394#comment-17116394 ] tigertan commented on KAFKA-10043: -- Some parameters will be overwritten which was confi

[jira] [Updated] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10043: - Description: When running the script of "kafka-consumer-perf-test.sh", some parameters which was  set  t

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10038: - Description: ConsumerPerformance.scala supports the setting of "client.id", which is a reasonable requi

[jira] [Updated] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10043: - Labels: perfomance (was: ) > Some parameters will be overwritten which was configured in consumer.conf

[jira] [Updated] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10043: - Summary: Some parameters will be overwritten which was configured in consumer.config where running "Con

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10038: - Description: ConsumerPerformance.scala supports the setting of "client.id", which is a reasonable requi

[jira] [Created] (KAFKA-10043) Running "ConsumerPerformance.scala" some parameters will be overwritten which was configured in consumer.config

2020-05-25 Thread tigertan (Jira)
tigertan created KAFKA-10043: Summary: Running "ConsumerPerformance.scala" some parameters will be overwritten which was configured in consumer.config Key: KAFKA-10043 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Updated] (KAFKA-9561) Update task input partitions when topic metadata changes

2020-05-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9561: --- Fix Version/s: 2.6.0 > Update task input partitions when topic metadata changes > ---

[jira] [Updated] (KAFKA-9146) Add option to force delete members in stream reset tool

2020-05-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9146: --- Fix Version/s: 2.6.0 > Add option to force delete members in stream reset tool >

[jira] [Created] (KAFKA-10042) Make INVALID_PRODUCER_EPOCH abortable from Produce response

2020-05-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10042: --- Summary: Make INVALID_PRODUCER_EPOCH abortable from Produce response Key: KAFKA-10042 URL: https://issues.apache.org/jira/browse/KAFKA-10042 Project: Kafka Is

[jira] [Resolved] (KAFKA-9472) Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED

2020-05-25 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9472. --- Resolution: Fixed > Reducing number of tasks for connector causes deleted tas

[jira] [Resolved] (KAFKA-3034) kafka.api.PlaintextConsumerTest > testSeek FAILED

2020-05-25 Thread Gwen Shapira (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3034. - Resolution: Fixed > kafka.api.PlaintextConsumerTest > testSeek FAILED > -

[jira] [Resolved] (KAFKA-3035) Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED

2020-05-25 Thread Gwen Shapira (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3035. - Resolution: Fixed > Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED > ---

[jira] [Resolved] (KAFKA-5034) Connect workers don't discover new Connector Plugins without Restart

2020-05-25 Thread Gwen Shapira (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-5034. - Resolution: Won't Do Assuming this was fixed since there were many iterations on connector loadin

[jira] [Resolved] (KAFKA-5000) Framework should log some progress information regularly to assist in troubleshooting

2020-05-25 Thread Gwen Shapira (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-5000. - Resolution: Fixed Metrics seem like a better indicator than logs. > Framework should log some pr

[jira] [Resolved] (KAFKA-3321) KafkaConfigStorage should never encounter commit without config data

2020-05-25 Thread Gwen Shapira (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3321. - Resolution: Won't Do Let's assume this was already resolved or at least the root cause isn't int

[jira] [Created] (KAFKA-10041) Kafka upgrade fails from 1.1 to 2.4/2.5/trunk fails due to failure in ZooKeeper

2020-05-25 Thread Zhuqi Jin (Jira)
Zhuqi Jin created KAFKA-10041: - Summary: Kafka upgrade fails from 1.1 to 2.4/2.5/trunk fails due to failure in ZooKeeper Key: KAFKA-10041 URL: https://issues.apache.org/jira/browse/KAFKA-10041 Project: Ka

[jira] [Updated] (KAFKA-9878) Block AddPartitionsToTxn call until the txn markers are committed

2020-05-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9878: --- Component/s: producer core > Block AddPartitionsToTxn call until the txn markers ar

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10038: Component/s: consumer > ConsumerPerformance.scala supports the setting of client.id >

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10038: Labels: newbie performance (was: performance) > ConsumerPerformance.scala supports the setting of

[jira] [Updated] (KAFKA-10040) Make computing the PreferredReplicaImbalanceCount metric more efficient

2020-05-25 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-10040: Summary: Make computing the PreferredReplicaImbalanceCount metric more efficient (was: Make Prefe

[jira] [Created] (KAFKA-10040) Make PreferredReplicaImbalanceCount more efficient

2020-05-25 Thread David Jacot (Jira)
David Jacot created KAFKA-10040: --- Summary: Make PreferredReplicaImbalanceCount more efficient Key: KAFKA-10040 URL: https://issues.apache.org/jira/browse/KAFKA-10040 Project: Kafka Issue Type:

[GitHub] [kafka] itantiger commented on pull request #8698: KAFKA-10022:console-producer supports the setting of client.id

2020-05-25 Thread GitBox
itantiger commented on pull request #8698: URL: https://github.com/apache/kafka/pull/8698#issuecomment-633573331 We can add client.id through configuration file such as producer.config or consumer.config, What is the purpose of this patch? -

[jira] [Created] (KAFKA-10039) A Kafka broker is gracefully shutdown, and incorrect metadata was passed to the Kafka connect client.

2020-05-25 Thread MinsuJo (Jira)
MinsuJo created KAFKA-10039: --- Summary: A Kafka broker is gracefully shutdown, and incorrect metadata was passed to the Kafka connect client. Key: KAFKA-10039 URL: https://issues.apache.org/jira/browse/KAFKA-10039

[GitHub] [kafka] cadonna commented on a change in pull request #8716: KAFKA-6145: KIP-441: Fix assignor config passthough

2020-05-25 Thread GitBox
cadonna commented on a change in pull request #8716: URL: https://github.com/apache/kafka/pull/8716#discussion_r429927490 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfigurationTest.java ## @@ -0,0 +1,36 @@ +/* + * Lice

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread tigertan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tigertan updated KAFKA-10038: - Description: ConsumerPerformance.scala supports the setting of "client.id", which is a reasonable requi

[GitHub] [kafka] cadonna commented on a change in pull request #8697: KAFKA-9983: KIP-613, add INFO level e2e latency metrics

2020-05-25 Thread GitBox
cadonna commented on a change in pull request #8697: URL: https://github.com/apache/kafka/pull/8697#discussion_r429904772 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java ## @@ -642,6 +651,55 @@ public static void

[GitHub] [kafka] cadonna commented on a change in pull request #8697: KAFKA-9983: KIP-613, add INFO level e2e latency metrics

2020-05-25 Thread GitBox
cadonna commented on a change in pull request #8697: URL: https://github.com/apache/kafka/pull/8697#discussion_r429814548 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java ## @@ -260,6 +261,43 @@ public void

[jira] [Created] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread tigertan (Jira)
tigertan created KAFKA-10038: Summary: ConsumerPerformance.scala supports the setting of client.id Key: KAFKA-10038 URL: https://issues.apache.org/jira/browse/KAFKA-10038 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

2020-05-25 Thread Mateusz Jadczyk (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115954#comment-17115954 ] Mateusz Jadczyk commented on KAFKA-9891: [~mjsax] if this is true  > _Restart ins

[GitHub] [kafka] srpanwar-confluent opened a new pull request #8723: KAFKA-9494: DescribeConfigsResponse - include additional metadata information

2020-05-25 Thread GitBox
srpanwar-confluent opened a new pull request #8723: URL: https://github.com/apache/kafka/pull/8723 Implements [KIP-569](https://cwiki.apache.org/confluence/display/KAFKA/KIP-569%3A+DescribeConfigsResponse+-+Update+the+schema+to+include+additional+metadata+information+of+the+field) Adds

[jira] [Created] (KAFKA-10037) Kafka offset commit response timeout and heartbeat response timeout

2020-05-25 Thread bingbing (Jira)
bingbing created KAFKA-10037: Summary: Kafka offset commit response timeout and heartbeat response timeout Key: KAFKA-10037 URL: https://issues.apache.org/jira/browse/KAFKA-10037 Project: Kafka