[jira] [Created] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

Boyang Chen created KAFKA-9475: -- Summary: Replace transaction abortion scheduler with a delayed queue Key: KAFKA-9475 URL: https://issues.apache.org/jira/browse/KAFKA-9475 Project: Kafka Issue

[jira] [Assigned] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

[ https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9447: -- Assignee: Boyang Chen > Add examples for EOS standalone and group mode under kafka/examples >

[jira] [Updated] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9254: --- Affects Version/s: 2.1.1 2.2.2 2.4.0

[jira] [Resolved] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9254. Fix Version/s: 2.4.1 2.3.2 2.2.3

[jira] [Commented] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023343#comment-17023343 ] Ismael Juma commented on KAFKA-9473: I think 

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

[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023325#comment-17023325 ] Konstantine Karantasis commented on KAFKA-9472: --- Sounds good. Thanks for taking a closer

[jira] [Assigned] (KAFKA-8382) Add TimestampedSessionStore

[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-8382: --- Assignee: highluck > Add TimestampedSessionStore > --- > >

[jira] [Commented] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023315#comment-17023315 ] ASF GitHub Bot commented on KAFKA-9254: --- hachikuji commented on pull request #7870: KAFKA-9254:

[jira] [Commented] (KAFKA-8843) Zookeeper migration tool support for TLS

[ https://issues.apache.org/jira/browse/KAFKA-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023299#comment-17023299 ] ASF GitHub Bot commented on KAFKA-8843: --- rondagostino commented on pull request #8003: KAFKA-8843:

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

[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023297#comment-17023297 ] Chris Egerton commented on KAFKA-9472: -- After looking into this a bit I suspect the root cause is

[jira] [Commented] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023287#comment-17023287 ] Boyang Chen commented on KAFKA-9473: ``` [2020-01-24 07:53:17,594] ERROR [KafkaServer id=1] Fatal

[jira] [Resolved] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9152. Resolution: Fixed > Improve Sensor Retrieval > - > > Key:

[jira] [Updated] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9152: --- Fix Version/s: 2.5.0 > Improve Sensor Retrieval > - > >

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023283#comment-17023283 ] ASF GitHub Bot commented on KAFKA-9152: --- bbejeck commented on pull request #7928: KAFKA-9152;

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

[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023280#comment-17023280 ] Konstantine Karantasis commented on KAFKA-9472: --- I overlooked the backing stores. But, yes,

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

[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023271#comment-17023271 ] Chris Egerton commented on KAFKA-9472: -- [~kkonstantine] the issues may be similar but I don't see

[jira] [Assigned] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8803: -- Assignee: Sophie Blee-Goldman (was: Boyang Chen) > Stream will not start due to

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

[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023264#comment-17023264 ] Konstantine Karantasis commented on KAFKA-9472: --- Thanks for reporting [~ChrisEgerton] I’m

[jira] [Created] (KAFKA-9474) Kafka RPC protocol should support type 'double'

Brian Byrne created KAFKA-9474: -- Summary: Kafka RPC protocol should support type 'double' Key: KAFKA-9474 URL: https://issues.apache.org/jira/browse/KAFKA-9474 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh updated KAFKA-9254: --- Summary: Updating Kafka Broker configuration dynamically twice reverts log configuration to default

[jira] [Resolved] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9462. -- Reviewer: Randall Hauch Resolution: Fixed Thanks, [~yuzhih...@gmail.com]. Merged to the

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Priority: Trivial (was: Minor) > Correct exception message in DistributedHerder >

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Issue Type: Bug (was: Improvement) > Correct exception message in DistributedHerder >

[jira] [Assigned] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-9462: Assignee: Ted Yu > Correct exception message in DistributedHerder >

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Issue Type: Improvement (was: Bug) > Correct exception message in DistributedHerder >

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Affects Version/s: 2.4.0 > Correct exception message in DistributedHerder >

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Fix Version/s: 2.5.0 > Correct exception message in DistributedHerder >

[jira] [Commented] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023221#comment-17023221 ] ASF GitHub Bot commented on KAFKA-9462: --- rhauch commented on pull request #7995: KAFKA-9462:

[jira] [Updated] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9462: - Component/s: KafkaConnect > Correct exception message in DistributedHerder >

[jira] [Updated] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9473: --- Description: By running a full set of core system tests, we detected 38/166 test failures which are

[jira] [Updated] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9473: --- Description: By running a full set of core system

[jira] [Created] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

Boyang Chen created KAFKA-9473: -- Summary: A large number of core system tests failing due to Kafka server failed to start on trunk Key: KAFKA-9473 URL: https://issues.apache.org/jira/browse/KAFKA-9473

[jira] [Updated] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7317: --- Fix Version/s: 2.5.0 > Use collections subscription for main consumer to reduce metadata >

[jira] [Resolved] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7317. Resolution: Fixed > Use collections subscription for main consumer to reduce metadata >

[jira] [Resolved] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8821. Resolution: Fixed Resolved via [https://github.com/apache/kafka/pull/7969] > Avoid pattern

[jira] [Updated] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8821: --- Fix Version/s: 2.5.0 > Avoid pattern subscription to allow for stricter ACL settings >

[jira] [Commented] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023198#comment-17023198 ] ASF GitHub Bot commented on KAFKA-7317: --- bbejeck commented on pull request #7969: KAFKA-7317: Use

[jira] [Resolved] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-9471. --- Resolution: Duplicate > Throw exception for DEAD StreamThread.State >

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022980#comment-17022980 ] Vito Jeng commented on KAFKA-9471: -- [~yuzhih...@gmail.com] Yes, I would be include this in KIP-216. >

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022970#comment-17022970 ] Ted Yu commented on KAFKA-9471: --- [~vitojeng] Please let me know if I should proceed with this or, do you

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022968#comment-17022968 ] Vito Jeng commented on KAFKA-9471: -- [~yuzhih...@gmail.com] Yes. Currently,

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982 ] Oleksii Boiko edited comment on KAFKA-8803 at 1/24/20 11:10 AM: Hi all,

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982 ] Oleksii Boiko edited comment on KAFKA-8803 at 1/24/20 11:09 AM: Hi all,

[jira] [Resolved] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9181. --- Fix Version/s: 2.5.0 Reviewer: Jason Gustafson Resolution: Fixed > Flaky

[jira] [Commented] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022848#comment-17022848 ] ASF GitHub Bot commented on KAFKA-9181: --- rajinisivaram commented on pull request #7941: KAFKA-9181;