[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: --- Component/s: streams > Iterating over cache with get(key) is inefficient >

[jira] [Updated] (KAFKA-8093) Fix JavaDoc markup

[ https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8093: --- Description: Running `./gradlew install` gives the following warning {code:java}

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790251#comment-16790251 ] Matthias J. Sax commented on KAFKA-7965: Failed with new error message:

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790244#comment-16790244 ] Yaroslav Tkachenko commented on KAFKA-7273: --- Created KIP: 

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790233#comment-16790233 ] Matthias J. Sax commented on KAFKA-7965: 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=16790234#comment-16790234 ] Matthias J. Sax commented on KAFKA-7937:

[jira] [Comment Edited] (KAFKA-8020) Consider changing design of ThreadCache

[ https://issues.apache.org/jira/browse/KAFKA-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790173#comment-16790173 ] Richard Yu edited comment on KAFKA-8020 at 3/12/19 3:09 AM: Oh about

[jira] [Commented] (KAFKA-8020) Consider changing design of ThreadCache

[ https://issues.apache.org/jira/browse/KAFKA-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790173#comment-16790173 ] Richard Yu commented on KAFKA-8020: --- Oh about implementing this policy for all caches. I'm not too sure

[jira] [Commented] (KAFKA-8020) Consider changing design of ThreadCache

[ https://issues.apache.org/jira/browse/KAFKA-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790171#comment-16790171 ] Richard Yu commented on KAFKA-8020: --- Hi [~mjsax] Well, elements which have been inserted usually have

[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=16790080#comment-16790080 ] Sophie Blee-Goldman commented on KAFKA-8094: That said, maybe this is another occasion to

[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=16790070#comment-16790070 ] Sophie Blee-Goldman commented on KAFKA-8094: After some investigation, the solution is not as

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790069#comment-16790069 ] Jeff Beagley commented on KAFKA-7157: - I believe, through writing my own SMT, I have found a

[jira] [Commented] (KAFKA-8040) Streams needs to handle timeout in initTransactions

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

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

Sophie Blee-Goldman created KAFKA-8094: -- Summary: Iterating over cache with get(key) is inefficient Key: KAFKA-8094 URL: https://issues.apache.org/jira/browse/KAFKA-8094 Project: Kafka

[jira] [Created] (KAFKA-8093) Fix JavaDoc markup

Matthias J. Sax created KAFKA-8093: -- Summary: Fix JavaDoc markup Key: KAFKA-8093 URL: https://issues.apache.org/jira/browse/KAFKA-8093 Project: Kafka Issue Type: Bug Components:

[jira] [Issue Comment Deleted] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7971: --- Comment: was deleted (was: Cross posted as question on SO:

[jira] [Commented] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789930#comment-16789930 ] Matthias J. Sax commented on KAFKA-7971: Thanks [~redguy666] – seems I copied the wrong link. >

[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=16789925#comment-16789925 ] Matthias J. Sax commented on KAFKA-8063: Failed again:

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

[ https://issues.apache.org/jira/browse/KAFKA-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8063: --- Fix Version/s: 2.2.1 > Flaky Test WorkerTest#testConverterOverrides >

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

[ https://issues.apache.org/jira/browse/KAFKA-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8063: --- Affects Version/s: 2.2.0 > Flaky Test WorkerTest#testConverterOverrides >

[jira] [Created] (KAFKA-8092) Flaky Test GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroupDescribeAccess

Matthias J. Sax created KAFKA-8092: -- Summary: Flaky Test GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroupDescribeAccess Key: KAFKA-8092 URL: https://issues.apache.org/jira/browse/KAFKA-8092

[jira] [Commented] (KAFKA-7224) KIP-328: Add spill-to-disk for Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789906#comment-16789906 ] ASF GitHub Bot commented on KAFKA-7224: --- vvcephei commented on pull request #6428: KAFKA-7224:

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789872#comment-16789872 ] Jose Armando Garcia Sancio commented on KAFKA-7565: --- The PR/patch above doesn't address

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789868#comment-16789868 ] ASF GitHub Bot commented on KAFKA-7565: --- jsancio commented on pull request #6427: KAFKA-7565:

[jira] [Resolved] (KAFKA-8091) Flaky test DynamicBrokerReconfigurationTest#testAddRemoveSaslListener

[ https://issues.apache.org/jira/browse/KAFKA-8091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8091. --- Resolution: Fixed Reviewer: Manikumar > Flaky test

[jira] [Commented] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789856#comment-16789856 ] Maciej Lizewski commented on KAFKA-7971: [~mjsax] this issue is cross posted as

[jira] [Commented] (KAFKA-8091) Flaky test DynamicBrokerReconfigurationTest#testAddRemoveSaslListener

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

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789769#comment-16789769 ] Lee Dongjin commented on KAFKA-7996: I double checked this issue, and found the following: 1. All of

[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: Bill Bejeck > StateListener is not notified when StreamThread dies >

[jira] [Assigned] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

[ https://issues.apache.org/jira/browse/KAFKA-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-8089: - Assignee: Rajini Sivaram > High level consumer from MirrorMaker is slow to deal with

[jira] [Commented] (KAFKA-7939) Flaky Test KafkaAdminClientTest#testCreateTopicsRetryBackoff

[ https://issues.apache.org/jira/browse/KAFKA-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789624#comment-16789624 ] ASF GitHub Bot commented on KAFKA-7939: --- omkreddy commented on pull request #6418: KAFKA-7939: Fix

[jira] [Resolved] (KAFKA-7939) Flaky Test KafkaAdminClientTest#testCreateTopicsRetryBackoff

[ https://issues.apache.org/jira/browse/KAFKA-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7939. -- Resolution: Fixed Issue resolved by pull request 6418 [https://github.com/apache/kafka/pull/6418] >

[jira] [Commented] (KAFKA-7976) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

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

[jira] [Commented] (KAFKA-8091) Flaky test DynamicBrokerReconfigurationTest#testAddRemoveSaslListener

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

[jira] [Commented] (KAFKA-7875) Add KStream#flatTransformValues

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

[jira] [Commented] (KAFKA-8090) Replace ControlledShutdown request/response with automated protocol

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

[jira] [Created] (KAFKA-8091) Flaky test DynamicBrokerReconfigurationTest#testAddRemoveSaslListener

Rajini Sivaram created KAFKA-8091: - Summary: Flaky test DynamicBrokerReconfigurationTest#testAddRemoveSaslListener Key: KAFKA-8091 URL: https://issues.apache.org/jira/browse/KAFKA-8091 Project:

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789383#comment-16789383 ] Valeria Vasylieva commented on KAFKA-6755: -- [~rhauch] thanks for the review! I have introduced

[jira] [Created] (KAFKA-8090) Replace ControlledShutdown request/response with automated protocol

Mickael Maison created KAFKA-8090: - Summary: Replace ControlledShutdown request/response with automated protocol Key: KAFKA-8090 URL: https://issues.apache.org/jira/browse/KAFKA-8090 Project: Kafka

[jira] [Resolved] (KAFKA-8072) Transient failure in SslSelectorTest.testCloseOldestConnectionWithMultipleStagedReceives

[ https://issues.apache.org/jira/browse/KAFKA-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8072. --- Resolution: Fixed Fix Version/s: (was: 2.2.1) (was: 2.3.0)

[jira] [Commented] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789251#comment-16789251 ] Abhi commented on KAFKA-7925: - [~rsivaram] [~ijuma] This issue is a blocker for our deployment. Can this be

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

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

[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=16789241#comment-16789241 ] Viktor Somogyi-Vass commented on KAFKA-8030: I'll take a look > Flaky Test >

[jira] [Commented] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

[ https://issues.apache.org/jira/browse/KAFKA-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789215#comment-16789215 ] Ismael Juma commented on KAFKA-8089: cc [~rsivaram] > High level consumer from MirrorMaker is slow

[jira] [Commented] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

[ https://issues.apache.org/jira/browse/KAFKA-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789201#comment-16789201 ] Henry Cai commented on KAFKA-8089: -- I looked at the latest Kafka 2.2.0 code, I don't see any change in

[jira] [Created] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

Henry Cai created KAFKA-8089: Summary: High level consumer from MirrorMaker is slow to deal with SSL certification expiration Key: KAFKA-8089 URL: https://issues.apache.org/jira/browse/KAFKA-8089