[jira] [Commented] (KAFKA-7801) TopicCommand should not be able to alter transaction topic partition count

[ https://issues.apache.org/jira/browse/KAFKA-7801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790262#comment-16790262 ] ASF GitHub Bot commented on KAFKA-7801: --- omkreddy commented on pull request #6109:

[jira] [Resolved] (KAFKA-7801) TopicCommand should not be able to alter transaction topic partition count

[ https://issues.apache.org/jira/browse/KAFKA-7801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7801. -- Resolution: Fixed Fix Version/s: 2.3.0 Issue resolved by pull request 6109 [https://github.com/a

[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&focusedCommentId=16790263#comment-16790263 ] Matthias J. Sax commented on KAFKA-8020: I think I understand your intention bett

[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} /Users/matth

[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&focusedCommentId=16790251#comment-16790251 ] Matthias J. Sax commented on KAFKA-7965: Failed with new error message: [https:/

[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&focusedCommentId=16790244#comment-16790244 ] Yaroslav Tkachenko commented on KAFKA-7273: --- Created KIP:  https://cwiki.apache

[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&focusedCommentId=16790233#comment-16790233 ] Matthias J. Sax commented on KAFKA-7965: Failed again: [https://builds.apache.or

[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&focusedCommentId=16790234#comment-16790234 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/job/kafka-pr-

[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&focusedCommentId=16790173#comment-16790173 ] Richard Yu edited comment on KAFKA-8020 at 3/12/19 3:09 AM: O

[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&focusedCommentId=16790173#comment-16790173 ] Richard Yu commented on KAFKA-8020: --- Oh about implementing this policy for all caches.

[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&focusedCommentId=16790171#comment-16790171 ] Richard Yu commented on KAFKA-8020: --- Hi [~mjsax] Well, elements which have been insert

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

[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&focusedCommentId=16790070#comment-16790070 ] Sophie Blee-Goldman commented on KAFKA-8094: After some investigation, the so

[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&focusedCommentId=16790069#comment-16790069 ] Jeff Beagley commented on KAFKA-7157: - I believe, through writing my own SMT, I have

[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&focusedCommentId=16790015#comment-16790015 ] ASF GitHub Bot commented on KAFKA-8040: --- bbejeck commented on pull request #6416: K

[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: Ka

[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: [https://stackoverflow.com/questi

[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&focusedCommentId=16789930#comment-16789930 ] Matthias J. Sax commented on KAFKA-7971: Thanks [~redguy666] – seems I copied the

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

[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&focusedCommentId=16789906#comment-16789906 ] ASF GitHub Bot commented on KAFKA-7224: --- vvcephei commented on pull request #6428:

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

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

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

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

[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 DynamicBrokerReconfigurationTest#te

[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&focusedCommentId=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&focusedCommentId=16789858#comment-16789858 ] ASF GitHub Bot commented on KAFKA-8091: --- rajinisivaram commented on pull request #6

[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&focusedCommentId=16789769#comment-16789769 ] Lee Dongjin commented on KAFKA-7996: I double checked this issue, and found the follo

[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 SSL

[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&focusedCommentId=16789624#comment-16789624 ] ASF GitHub Bot commented on KAFKA-7939: --- omkreddy commented on pull request #6418:

[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] > Fl

[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&focusedCommentId=16789559#comment-16789559 ] ASF GitHub Bot commented on KAFKA-7976: --- rajinisivaram commented on pull request #6

[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&focusedCommentId=16789444#comment-16789444 ] ASF GitHub Bot commented on KAFKA-8091: --- rajinisivaram commented on pull request #6

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

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

[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&focusedCommentId=16789416#comment-16789416 ] ASF GitHub Bot commented on KAFKA-8090: --- mimaison commented on pull request #6423:

[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: Kafk

[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&focusedCommentId=16789383#comment-16789383 ] Valeria Vasylieva commented on KAFKA-6755: -- [~rhauch] thanks for the review! I h

[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&focusedCommentId=16789251#comment-16789251 ] Abhi commented on KAFKA-7925: - [~rsivaram] [~ijuma] This issue is a blocker for our deploymen

[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 > TopicCommandWithAdminClientTest#

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