[jira] [Updated] (KAFKA-7502) Cleanup KTable materialization logic in a single place

2019-03-05 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7502: --- Priority: Major (was: Minor) > Cleanup KTable materialization logic in a single place >

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784298#comment-16784298 ] Abhi edited comment on KAFKA-7925 at 3/5/19 10:38 AM: -- Hi, I deploye

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784298#comment-16784298 ] Abhi commented on KAFKA-7925: - Hi, I deployed the patch in my setup but now I am getting belo

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784298#comment-16784298 ] Abhi edited comment on KAFKA-7925 at 3/5/19 10:35 AM: -- Hi, I deploye

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

2019-03-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784356#comment-16784356 ] ASF GitHub Bot commented on KAFKA-7976: --- rajinisivaram commented on pull request #6

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

2019-03-05 Thread Nikita Glashenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784366#comment-16784366 ] Nikita Glashenko commented on KAFKA-7703: - We stumbled upon this bug in productio

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784365#comment-16784365 ] Abhi commented on KAFKA-7925: - [~rsivaram] I am also seeing a similar exception when running

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

2019-03-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784373#comment-16784373 ] ASF GitHub Bot commented on KAFKA-7976: --- omkreddy commented on pull request #6358:

[jira] [Assigned] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7988: - Assignee: Rajini Sivaram > Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolRes

[jira] [Assigned] (KAFKA-7966) Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7966: - Assignee: Rajini Sivaram > Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerCon

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

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7976: - Assignee: Rajini Sivaram > Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeader

[jira] [Commented] (KAFKA-7966) Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784379#comment-16784379 ] Rajini Sivaram commented on KAFKA-7966: --- DynamicBrokerReconfiguration test creates

[jira] [Resolved] (KAFKA-7966) Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7966. --- Resolution: Duplicate > Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig > --

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

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784387#comment-16784387 ] Rajini Sivaram commented on KAFKA-7925: --- [~xabhi] Thank you for trying out the PR.

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784403#comment-16784403 ] Abhi commented on KAFKA-7925: - [~rsivaram] While look at the broker logs, I found multiple ja

[jira] [Commented] (KAFKA-6177) kafka-mirror-maker.sh RecordTooLargeException

2019-03-05 Thread Artem Chekunov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784442#comment-16784442 ] Artem Chekunov commented on KAFKA-6177: --- Hello there,   I had the same issue. In

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

2019-03-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784441#comment-16784441 ] Rajini Sivaram commented on KAFKA-7925: --- [~xabhi] Did you run a clean build using t

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784456#comment-16784456 ] Abhi commented on KAFKA-7925: - [~rsivaram] Did you run a clean build using the instructions M

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784456#comment-16784456 ] Abhi edited comment on KAFKA-7925 at 3/5/19 1:54 PM: - [~rsivaram] Did

[jira] [Updated] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

2019-03-05 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-8010: -- Attachment: image-2019-03-05-19-41-44-461.png > kafka-configs.sh does not allow setting config with an equal in

[jira] [Commented] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

2019-03-05 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784480#comment-16784480 ] Kartik commented on KAFKA-8010: --- [~mimaison] For me it's working.  Attaching the image, Ign

[jira] [Comment Edited] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

2019-03-05 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784480#comment-16784480 ] Kartik edited comment on KAFKA-8010 at 3/5/19 2:16 PM: --- [~mimaison]

[jira] [Updated] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

2019-03-05 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-8010: -- Attachment: (was: image-2019-03-05-19-41-44-461.png) > kafka-configs.sh does not allow setting config with

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784669#comment-16784669 ] Abhi commented on KAFKA-7925: - I tried the test again. I started the producer application to

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

2019-03-05 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhi updated KAFKA-7925: Attachment: jira-server.log-6 jira-server.log-5 jira-server.log-4 ji

[jira] [Created] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2019-03-05 Thread Adrian McCague (JIRA)
Adrian McCague created KAFKA-8042: - Summary: Kafka Streams creates many segment stores on state restore Key: KAFKA-8042 URL: https://issues.apache.org/jira/browse/KAFKA-8042 Project: Kafka Is

[jira] [Updated] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2019-03-05 Thread Adrian McCague (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian McCague updated KAFKA-8042: -- Description: Note that this from the perspective of one instance of an application, where ther

[jira] [Updated] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2019-03-05 Thread Adrian McCague (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian McCague updated KAFKA-8042: -- Description: Note that this from the perspective of one instance of an application, where ther

[jira] [Updated] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2019-03-05 Thread Adrian McCague (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian McCague updated KAFKA-8042: -- Description: Note that this is from the perspective of one instance of an application, where t

[jira] [Created] (KAFKA-8043) Host

2019-03-05 Thread Bolke de Bruin (JIRA)
Bolke de Bruin created KAFKA-8043: - Summary: Host Key: KAFKA-8043 URL: https://issues.apache.org/jira/browse/KAFKA-8043 Project: Kafka Issue Type: Bug Reporter: Bolke de Bruin

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-03-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784755#comment-16784755 ] Ted Yu commented on KAFKA-3729: --- Can AbstractProcessorContext#appConfigs() be used to obtai

[jira] [Resolved] (KAFKA-8043) Host

2019-03-05 Thread Bolke de Bruin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bolke de Bruin resolved KAFKA-8043. --- Resolution: Incomplete > Host > > > Key: KAFKA-8043 > UR

[jira] [Closed] (KAFKA-8043) Host

2019-03-05 Thread Bolke de Bruin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bolke de Bruin closed KAFKA-8043. - > Host > > > Key: KAFKA-8043 > URL: https://issues.apache.org/ji

[jira] [Created] (KAFKA-8044) System Test Failure: ReassignPartitionsTest.test_reassign_partitions

2019-03-05 Thread Manikumar (JIRA)
Manikumar created KAFKA-8044: Summary: System Test Failure: ReassignPartitionsTest.test_reassign_partitions Key: KAFKA-8044 URL: https://issues.apache.org/jira/browse/KAFKA-8044 Project: Kafka I

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-03-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784816#comment-16784816 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6325: K

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-03-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784828#comment-16784828 ] Guozhang Wang commented on KAFKA-3729: -- [~mjsax] Yes `configure()` is tended to be i

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-03-05 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7895: --- Fix Version/s: 2.1.2 > Ktable supress operator emitting more than one record for the same key per >

[jira] [Commented] (KAFKA-7978) Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

2019-03-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785044#comment-16785044 ] Matthias J. Sax commented on KAFKA-7978: One more: [https://builds.apache.org/jo

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

2019-03-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785078#comment-16785078 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6151: KAF

[jira] [Created] (KAFKA-8045) Possible Flaky Test LogOffsetTest.testGetOffsetsBeforeNow

2019-03-05 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8045: -- Summary: Possible Flaky Test LogOffsetTest.testGetOffsetsBeforeNow Key: KAFKA-8045 URL: https://issues.apache.org/jira/browse/KAFKA-8045 Project: Kafka Issue Typ

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

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

[jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-03-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-3729: -- Attachment: 3729.txt > Auto-configure non-default SerDes passed alongside the topology builder > -

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-03-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785119#comment-16785119 ] Ted Yu commented on KAFKA-3729: --- Attached tentative patch. If it is on right track, I can s

[jira] [Commented] (KAFKA-8046) Shutdown broker because all log dirs in /tmp/kafka-logs have failed

2019-03-05 Thread jaren (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785124#comment-16785124 ] jaren commented on KAFKA-8046: -- we use kafka_2.11_2.0.0 > Shutdown broker because all log d

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2019-03-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785127#comment-16785127 ] Guozhang Wang commented on KAFKA-8037: -- We use `offsetLimit` in ProcessorStateManage

[jira] [Created] (KAFKA-8046) Shutdown broker because all log dirs in /tmp/kafka-logs have failed

2019-03-05 Thread jaren (JIRA)
jaren created KAFKA-8046: Summary: Shutdown broker because all log dirs in /tmp/kafka-logs have failed Key: KAFKA-8046 URL: https://issues.apache.org/jira/browse/KAFKA-8046 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-03-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785144#comment-16785144 ] Guozhang Wang commented on KAFKA-7994: -- Just to add: even in the KIP to add negative

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-03-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785150#comment-16785150 ] Guozhang Wang commented on KAFKA-7994: -- | It wouldn't be terrible if we sometimes he

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

2019-03-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785201#comment-16785201 ] ASF GitHub Bot commented on KAFKA-8020: --- ConcurrencyPractitioner commented on pull

[jira] [Created] (KAFKA-8047) remove KafkaMbean when network close

2019-03-05 Thread limeng (JIRA)
limeng created KAFKA-8047: - Summary: remove KafkaMbean when network close Key: KAFKA-8047 URL: https://issues.apache.org/jira/browse/KAFKA-8047 Project: Kafka Issue Type: Bug Components: cl

[jira] [Created] (KAFKA-8048) remove KafkaMbean when network close

2019-03-05 Thread limeng (JIRA)
limeng created KAFKA-8048: - Summary: remove KafkaMbean when network close Key: KAFKA-8048 URL: https://issues.apache.org/jira/browse/KAFKA-8048 Project: Kafka Issue Type: Bug Components: cl

[jira] [Created] (KAFKA-8049) remove KafkaMbean when network close

2019-03-05 Thread limeng (JIRA)
limeng created KAFKA-8049: - Summary: remove KafkaMbean when network close Key: KAFKA-8049 URL: https://issues.apache.org/jira/browse/KAFKA-8049 Project: Kafka Issue Type: Bug Components: cl

[jira] [Created] (KAFKA-8050) remove KafkaMbean when network close

2019-03-05 Thread limeng (JIRA)
limeng created KAFKA-8050: - Summary: remove KafkaMbean when network close Key: KAFKA-8050 URL: https://issues.apache.org/jira/browse/KAFKA-8050 Project: Kafka Issue Type: Bug Components: cl

[jira] [Created] (KAFKA-8051) remove KafkaMbean when network close

2019-03-05 Thread limeng (JIRA)
limeng created KAFKA-8051: - Summary: remove KafkaMbean when network close Key: KAFKA-8051 URL: https://issues.apache.org/jira/browse/KAFKA-8051 Project: Kafka Issue Type: Bug Components: cl