[jira] [Commented] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796730#comment-16796730 ] ASF GitHub Bot commented on KAFKA-8125: --- huxihx commented on pull request #6472: KAFKA-8125: Skip

[jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

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

[jira] [Assigned] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8125: - Assignee: huxihx > Check for topic existence in CreateTopicsRequest prior to creating replica >

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796661#comment-16796661 ] Paul Whalen commented on KAFKA-: So I just went through looking at all the relevant interfaces

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796660#comment-16796660 ] JieFang.He commented on KAFKA-8127: --- I get the same result both in windows7 and Ubuntu with command:

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796650#comment-16796650 ] Matthias J. Sax commented on KAFKA-: No need to apologize, you did not "hijack" this ticket

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796648#comment-16796648 ] Paul Whalen commented on KAFKA-: I had that thought and definitely believe it's possible, but I

[jira] [Assigned] (KAFKA-7928) Deprecate WindowStore.put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7928: -- Assignee: Slim Ouertani > Deprecate WindowStore.put(key, value) >

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796604#comment-16796604 ] Matthias J. Sax commented on KAFKA-: [~pgwhalen] What you describe might be possible today

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796582#comment-16796582 ] Matthias J. Sax commented on KAFKA-7989: And again:

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796580#comment-16796580 ] Matthias J. Sax commented on KAFKA-7989:

[jira] [Created] (KAFKA-8129) Shade Kafka client dependencies

Colin P. McCabe created KAFKA-8129: -- Summary: Shade Kafka client dependencies Key: KAFKA-8129 URL: https://issues.apache.org/jira/browse/KAFKA-8129 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796519#comment-16796519 ] Paul Whalen commented on KAFKA-: This is a very interesting idea that I am suddenly very excited

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796490#comment-16796490 ] Patrik Kleindl commented on KAFKA-: --- [~mjsax] In

[jira] [Updated] (KAFKA-8062) StateListener is not notified when StreamThread dies

[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8062: --- Fix Version/s: 2.2.1 2.3.0 > StateListener is not notified when

[jira] [Updated] (KAFKA-8094) Iterating over cache with get(key) is inefficient

[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8094: --- Fix Version/s: 2.3.0 > Iterating over cache with get(key) is inefficient >

[jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796435#comment-16796435 ] Suman B N commented on KAFKA-6078: -- [~mjsax], Can I take a deeper look into it? Please assign the ticket

[jira] [Commented] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796426#comment-16796426 ] Matthias J. Sax commented on KAFKA-8123: Failed again:

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796425#comment-16796425 ] Matthias J. Sax commented on KAFKA-7989: Failed again:

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796424#comment-16796424 ] Matthias J. Sax commented on KAFKA-7937: Failed again:

[jira] [Commented] (KAFKA-8063) Flaky Test WorkerTest#testConverterOverrides

[ https://issues.apache.org/jira/browse/KAFKA-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796421#comment-16796421 ] Matthias J. Sax commented on KAFKA-8063: Failed again:

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6078: --- Component/s: core > Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6078: --- Labels: flaky-test (was: ) > Investigate failure of

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6078: --- Priority: Critical (was: Major) > Investigate failure of

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6078: --- Affects Version/s: 2.3.0 > Investigate failure of

[jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796420#comment-16796420 ] Matthias J. Sax commented on KAFKA-6078: Failed again:

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6078: --- Fix Version/s: 2.3.0 > Investigate failure of

[jira] [Assigned] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-8123: - Assignee: Anna Povzner (was: Rajini Sivaram) > Flaky Test >

[jira] [Assigned] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7989: - Assignee: Anna Povzner (was: Rajini Sivaram) > Flaky Test >

[jira] [Commented] (KAFKA-8094) Iterating over cache with get(key) is inefficient

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

[jira] [Resolved] (KAFKA-8094) Iterating over cache with get(key) is inefficient

[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8094. Resolution: Fixed > Iterating over cache with get(key) is inefficient >

[jira] [Assigned] (KAFKA-8094) Iterating over cache with get(key) is inefficient

[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8094: -- Assignee: Sophie Blee-Goldman > Iterating over cache with get(key) is inefficient >

[jira] [Commented] (KAFKA-8062) StateListener is not notified when StreamThread dies

[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796140#comment-16796140 ] Bill Bejeck commented on KAFKA-8062: cherry-picked to 2.2 as well > StateListener is not notified

[jira] [Updated] (KAFKA-8128) Dynamic delegation token change possibility for consumer/producer

[ https://issues.apache.org/jira/browse/KAFKA-8128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-8128: - Affects Version/s: 2.2.0 > Dynamic delegation token change possibility for consumer/producer >

[jira] [Commented] (KAFKA-8128) Dynamic delegation token change possibility for consumer/producer

[ https://issues.apache.org/jira/browse/KAFKA-8128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796147#comment-16796147 ] Gabor Somogyi commented on KAFKA-8128: -- cc [~viktorsomogyi] maybe interesting for you. > Dynamic

[jira] [Created] (KAFKA-8128) Dynamic delegation token change possibility for consumer/producer

Gabor Somogyi created KAFKA-8128: Summary: Dynamic delegation token change possibility for consumer/producer Key: KAFKA-8128 URL: https://issues.apache.org/jira/browse/KAFKA-8128 Project: Kafka

[jira] [Resolved] (KAFKA-8062) StateListener is not notified when StreamThread dies

[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8062. Resolution: Fixed > StateListener is not notified when StreamThread dies >

[jira] [Commented] (KAFKA-8062) StateListener is not notified when StreamThread dies

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

[jira] [Assigned] (KAFKA-8062) StateListener is not notified when StreamThread dies

[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8062: -- Assignee: Guozhang Wang (was: Bill Bejeck) > StateListener is not notified when StreamThread

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796005#comment-16796005 ] Slim Ouertani commented on KAFKA-8127: -- What the the command used to build and the OS ? >> io is

[jira] [Comment Edited] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796005#comment-16796005 ] Slim Ouertani edited comment on KAFKA-8127 at 3/19/19 12:01 PM: What the

[jira] [Assigned] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7989: - Assignee: Rajini Sivaram > Flaky Test >

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796000#comment-16796000 ] ASF GitHub Bot commented on KAFKA-8127: --- hejiefang commented on pull request #6470: KAFKA-8127 It

[jira] [Comment Edited] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795993#comment-16795993 ] Valeria Vasylieva edited comment on KAFKA-6675 at 3/19/19 11:39 AM:

[jira] [Commented] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795993#comment-16795993 ] Valeria Vasylieva commented on KAFKA-6675: -- [~rhauch] I have investigated the actual log: if we

[jira] [Comment Edited] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795993#comment-16795993 ] Valeria Vasylieva edited comment on KAFKA-6675 at 3/19/19 11:30 AM:

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795966#comment-16795966 ] Jingguo Yao commented on KAFKA-5998: After we restarted a streaming application, we also got the

[jira] [Comment Edited] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795965#comment-16795965 ] Viktor Somogyi-Vass edited comment on KAFKA-8030 at 3/19/19 10:46 AM:

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795965#comment-16795965 ] Viktor Somogyi-Vass commented on KAFKA-8030: Started working on this, now trying to

[jira] [Commented] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795837#comment-16795837 ] Valeria Vasylieva commented on KAFKA-6675: -- I would like to work on it > Connect workers should

[jira] [Assigned] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeria Vasylieva reassigned KAFKA-6675: Assignee: Valeria Vasylieva > Connect workers should log plugin path and

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795825#comment-16795825 ] ASF GitHub Bot commented on KAFKA-8127: --- hejiefang commented on pull request #6470: KAFKA-8127 It

[jira] [Assigned] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-8123: - Assignee: Rajini Sivaram > Flaky Test >

[jira] [Updated] (KAFKA-8127) It may need to import scala.io

[ https://issues.apache.org/jira/browse/KAFKA-8127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated KAFKA-8127: -- Issue Type: Improvement (was: Bug) > It may need to import scala.io > --

[jira] [Created] (KAFKA-8127) It may need to import scala.io

JieFang.He created KAFKA-8127: - Summary: It may need to import scala.io Key: KAFKA-8127 URL: https://issues.apache.org/jira/browse/KAFKA-8127 Project: Kafka Issue Type: Bug Reporter: