[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795714#comment-16795714 ] Manikumar commented on KAFKA-8106: -- [~Flower.min] Instructions for the submitting code

[jira] [Comment Edited] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795688#comment-16795688 ] Flower.min edited comment on KAFKA-8106 at 3/19/19 5:17 AM:  

[jira] [Comment Edited] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795688#comment-16795688 ] Flower.min edited comment on KAFKA-8106 at 3/19/19 5:15 AM:  

[jira] [Comment Edited] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795688#comment-16795688 ] Flower.min edited comment on KAFKA-8106 at 3/19/19 5:14 AM:  

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795688#comment-16795688 ] Flower.min commented on KAFKA-8106: ---  We do performance testing again with package

[jira] [Created] (KAFKA-8126) Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask

Guozhang Wang created KAFKA-8126: Summary: Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask Key: KAFKA-8126 URL: https://issues.apache.org/jira/browse/KAFKA-8126 Project: Kafka

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795523#comment-16795523 ] Jun Rao commented on KAFKA-7504: [~cwaldrop], thanks for helping test this out. It would

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

Lucas Bradstreet created KAFKA-8125: --- Summary: Check for topic existence in CreateTopicsRequest prior to creating replica assignment Key: KAFKA-8125 URL: https://issues.apache.org/jira/browse/KAFKA-8125

[jira] [Created] (KAFKA-8124) Beginning offset is after the ending offset for topic partition

suseendramani created KAFKA-8124: Summary: Beginning offset is after the ending offset for topic partition Key: KAFKA-8124 URL: https://issues.apache.org/jira/browse/KAFKA-8124 Project: Kafka

[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=16795460#comment-16795460 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[jira] [Commented] (KAFKA-8031) Flaky Test UserClientIdQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795461#comment-16795461 ] Matthias J. Sax commented on KAFKA-8031: Failed again: [https://builds.apache.or

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

Matthias J. Sax created KAFKA-8123: -- Summary: Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated Key: KAFKA-8123 URL: https://issues.apache.org/jira/browse/KAFKA-8123

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Affects Version/s: 2.3.0 > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete > -

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Component/s: unit tests core > Flaky Test kafka.api.ClientIdQuotaTest.testQu

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Fix Version/s: 2.3.0 > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete > -

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Labels: flaky-test (was: ) > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Issue Type: Bug (was: Improvement) > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrid

[jira] [Issue Comment Deleted] (KAFKA-8031) Flaky Test UserClientIdQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8031: --- Comment: was deleted (was: Failed again: [https://builds.apache.org/blue/organizations/jenki

[jira] [Commented] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795463#comment-16795463 ] Matthias J. Sax commented on KAFKA-8107: Failed again:  [https://builds.apache.or

[jira] [Updated] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8107: --- Priority: Critical (was: Major) > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDe

[jira] [Resolved] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8107. Resolution: Duplicate > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete > --

[jira] [Reopened] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8107: > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete >

[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&focusedCommentId=16795459#comment-16795459 ] ASF GitHub Bot commented on KAFKA-8062: --- guozhangwang commented on pull request #64

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795434#comment-16795434 ] Cabe Waldrop commented on KAFKA-7504: - [~attawaykl] and I would like to volunteer to 

[jira] [Updated] (KAFKA-8035) Add tests for generics in KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Description: During the work on KAFKA-4217, it was discovered that some combinations of Java gen

[jira] [Commented] (KAFKA-7858) Replace JoinGroup request/response with automated protocol

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

[jira] [Commented] (KAFKA-5492) LogRecoveryTest.testHWCheckpointWithFailuresSingleLogSegment transient failure

[ https://issues.apache.org/jira/browse/KAFKA-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795359#comment-16795359 ] Matthias J. Sax commented on KAFKA-5492: Seems to be a duplicate of KAFKA-6409 ?

[jira] [Commented] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795358#comment-16795358 ] Matthias J. Sax commented on KAFKA-6409: Seems to be a duplicate of KAFKA-5492 ?

[jira] [Resolved] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

[ https://issues.apache.org/jira/browse/KAFKA-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8121. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.2.1

[jira] [Commented] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

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

[jira] [Assigned] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8078: -- Assignee: Matthias J. Sax > Flaky Test TableTableJoinIntegrationTest#testInnerInner >

[jira] [Created] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

Matthias J. Sax created KAFKA-8122: -- Summary: Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState Key: KAFKA-8122 URL: https://issues.apache.org/jira/browse/KAFKA-8122 Project: K

[jira] [Assigned] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8122: -- Assignee: Matthias J. Sax > Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTask

[jira] [Commented] (KAFKA-4925) Add a configurable delay to the initial consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795212#comment-16795212 ] Antony Stubbs commented on KAFKA-4925: -- Relates to: KAFKA-7725 Add a delay for furth

[jira] [Updated] (KAFKA-8035) Add tests for generics in KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8035: - Labels: unit-test (was: ) > Add tests for generics in KStream API > ---

[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=16795173#comment-16795173 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[jira] [Commented] (KAFKA-8120) Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795091#comment-16795091 ] Chris Egerton commented on KAFKA-8120: -- [~coolboi567] how large is the file you're r

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

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

[jira] [Commented] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

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

[jira] [Commented] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

[ https://issues.apache.org/jira/browse/KAFKA-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794972#comment-16794972 ] Shengnan YU commented on KAFKA-8100: Does anyone have a loot at this issue? > If del

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794970#comment-16794970 ] Oleg Kuznetsov commented on KAFKA-2480: --- Then a lot of open source connectors misus

[jira] [Created] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

Rajini Sivaram created KAFKA-8121: - Summary: ZooKeeperClient session expiry thread may leave clients behind after close Key: KAFKA-8121 URL: https://issues.apache.org/jira/browse/KAFKA-8121 Project: K

[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=16794890#comment-16794890 ] Valeria Vasylieva commented on KAFKA-6755: -- [~rhauch]  KIP discussion has only o

[jira] [Resolved] (KAFKA-8118) Ensure that tests close ZooKeeper clients since they can impact subsequent tests

[ https://issues.apache.org/jira/browse/KAFKA-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8118. --- Resolution: Fixed Reviewer: Ismael Juma > Ensure that tests close ZooKeeper clients sin

[jira] [Commented] (KAFKA-8118) Ensure that tests close ZooKeeper clients since they can impact subsequent tests

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

[jira] [Created] (KAFKA-8120) Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka

Prashant Shahi created KAFKA-8120: - Summary: Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka Key: KAFKA-8120 URL: https://issues.apache.org/jira/browse/KAFKA-8120 Pro

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794810#comment-16794810 ] Michal Turek commented on KAFKA-3539: - Hi [~spyridon.ninos], ticket close won't fix t