[jira] [Updated] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5530: -- Description: Dears, There are problems with balancer in KStreams, when

[jira] [Updated] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5530: -- Description: Dears, There are problems with balancer in KStreams, when

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067798#comment-16067798 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5167: --- [~mjsax] OK. But be

[jira] [Created] (KAFKA-5535) Transformations - tranformations for value broken on tombsone events

Yelei Wu created KAFKA-5535: --- Summary: Transformations - tranformations for value broken on tombsone events Key: KAFKA-5535 URL: https://issues.apache.org/jira/browse/KAFKA-5535 Project: Kafka Iss

[jira] [Resolved] (KAFKA-5521) Support replicas movement between log directories (KIP-113)

[ https://issues.apache.org/jira/browse/KAFKA-5521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5521. - Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-5163 > Support replicas mo

[jira] [Comment Edited] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067579#comment-16067579 ] Sandokan Dias edited comment on KAFKA-3450 at 6/29/17 2:28 AM: -

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067579#comment-16067579 ] Sandokan Dias commented on KAFKA-3450: -- Same problem here when the topic.auto.create

[jira] [Commented] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

[ https://issues.apache.org/jira/browse/KAFKA-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067569#comment-16067569 ] ASF GitHub Bot commented on KAFKA-5402: --- GitHub user rajinisivaram reopened a pull r

[jira] [Commented] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

[ https://issues.apache.org/jira/browse/KAFKA-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067529#comment-16067529 ] ASF GitHub Bot commented on KAFKA-5402: --- Github user rajinisivaram closed the pull r

[jira] [Commented] (KAFKA-5458) SASL handshake fails for METADATA requests

[ https://issues.apache.org/jira/browse/KAFKA-5458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067491#comment-16067491 ] Rajini Sivaram commented on KAFKA-5458: --- [~Sagar Lad] Can you provide full matching

[jira] [Assigned] (KAFKA-5534) KafkaConsumer offsetsForTimes should include partitions in result even if no offset could be found

[ https://issues.apache.org/jira/browse/KAFKA-5534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5534: -- Assignee: Vahid Hashemian > KafkaConsumer offsetsForTimes should include partitions in

[jira] [Commented] (KAFKA-5526) ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067469#comment-16067469 ] Vahid Hashemian commented on KAFKA-5526: [~hachikuji] Sounds good. I'll start draf

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067362#comment-16067362 ] Matthias J. Sax commented on KAFKA-5167: [~habdank] Seems you created https://issu

[jira] [Commented] (KAFKA-5526) ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067286#comment-16067286 ] Jason Gustafson commented on KAFKA-5526: [~vahid] That's a good question. I was di

[jira] [Created] (KAFKA-5534) KafkaConsumer offsetsForTimes should include partitions in result even if no offset could be found

Jason Gustafson created KAFKA-5534: -- Summary: KafkaConsumer offsetsForTimes should include partitions in result even if no offset could be found Key: KAFKA-5534 URL: https://issues.apache.org/jira/browse/KAFKA-55

[jira] [Commented] (KAFKA-5522) ListOffset should take LSO into account when searching by timestamp

[ https://issues.apache.org/jira/browse/KAFKA-5522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067175#comment-16067175 ] ASF GitHub Bot commented on KAFKA-5522: --- GitHub user hachikuji opened a pull request

[jira] [Commented] (KAFKA-5490) Deletion of tombstones during cleaning should consider idempotent message retention

[ https://issues.apache.org/jira/browse/KAFKA-5490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067027#comment-16067027 ] ASF GitHub Bot commented on KAFKA-5490: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066927#comment-16066927 ] Nishkam Ravi commented on KAFKA-5528: - Hi [~damianguy], IllegalStateException gets thr

[jira] [Commented] (KAFKA-5526) ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066909#comment-16066909 ] Vahid Hashemian commented on KAFKA-5526: [~hachikuji] Thanks for clarifying. It ma

[jira] [Commented] (KAFKA-5514) KafkaConsumer ignores default values in Properties object because of incorrect use of Properties object.

[ https://issues.apache.org/jira/browse/KAFKA-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066876#comment-16066876 ] Kamal Chandraprakash commented on KAFKA-5514: - Geert Schuring, What do you me

[jira] [Commented] (KAFKA-5526) ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066866#comment-16066866 ] Jason Gustafson commented on KAFKA-5526: I suppose what I'm suggesting is that we

[jira] [Created] (KAFKA-5533) Timestamp-based log compaction

Eno Thereska created KAFKA-5533: --- Summary: Timestamp-based log compaction Key: KAFKA-5533 URL: https://issues.apache.org/jira/browse/KAFKA-5533 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values

[ https://issues.apache.org/jira/browse/KAFKA-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066695#comment-16066695 ] ASF GitHub Bot commented on KAFKA-5379: --- GitHub user twbecker opened a pull request:

[jira] [Commented] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry

[ https://issues.apache.org/jira/browse/KAFKA-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066670#comment-16066670 ] Benjamin Bargeton commented on KAFKA-5398: -- Thanks a lot for your answer too, and

[jira] [Commented] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066607#comment-16066607 ] ASF GitHub Bot commented on KAFKA-5532: --- GitHub user ppatierno opened a pull request

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066606#comment-16066606 ] Damian Guy commented on KAFKA-5528: --- Hi [~nravi] Can you provide any more information?

[jira] [Commented] (KAFKA-5483) Shutdown of scheduler should come after LogManager

[ https://issues.apache.org/jira/browse/KAFKA-5483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066603#comment-16066603 ] ASF GitHub Bot commented on KAFKA-5483: --- GitHub user mimaison opened a pull request:

[jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5532: -- Component/s: tools > Making bootstrap.servers property a first citizen option for the > Produce

[jira] [Created] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

Paolo Patierno created KAFKA-5532: - Summary: Making bootstrap.servers property a first citizen option for the ProducerPerformance Key: KAFKA-5532 URL: https://issues.apache.org/jira/browse/KAFKA-5532

[jira] [Assigned] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neil reassigned KAFKA-5515: --- Assignee: Neil > Consider removing date formatting from Segments class >

[jira] [Created] (KAFKA-5531) Check exception handling in all streams tests

Eno Thereska created KAFKA-5531: --- Summary: Check exception handling in all streams tests Key: KAFKA-5531 URL: https://issues.apache.org/jira/browse/KAFKA-5531 Project: Kafka Issue Type: Sub-tas

[jira] [Commented] (KAFKA-4047) Return more useful information from ConsumerGroupCommand for consumer groups that are rebalancing or manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066429#comment-16066429 ] Xiaoju Wu commented on KAFKA-4047: -- [~vahid] With the patch in KAFKA-3853, are informatio

[jira] [Commented] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values

[ https://issues.apache.org/jira/browse/KAFKA-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066393#comment-16066393 ] Tommy Becker commented on KAFKA-5379: - Hey [~guozhang], I should have a PR ready prett

[jira] [Updated] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5006: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > KeyValueStore.put may throw exception

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066296#comment-16066296 ] ASF GitHub Bot commented on KAFKA-5233: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5530: -- Description: Dears, There are problems with balancer in KStreams, when

[jira] [Updated] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5530: -- Description: Dears, There are problems with balancer in KStreams, when

[jira] [Updated] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5530: -- Docs Text: Dears, There are problems with balancer in KStreams, when nu

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066185#comment-16066185 ] Alexandre Savio commented on KAFKA-3450: I've got the same issue too. > Producer

[jira] [Commented] (KAFKA-5529) ConsoleProducer uses deprecated BaseProducer

[ https://issues.apache.org/jira/browse/KAFKA-5529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066114#comment-16066114 ] ASF GitHub Bot commented on KAFKA-5529: --- GitHub user evis opened a pull request:

[jira] [Created] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

Seweryn Habdank-Wojewodzki created KAFKA-5530: - Summary: Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-) Key: KAFKA-5530 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-5529) ConsoleProducer uses deprecated BaseProducer

Evgeny Veretennikov created KAFKA-5529: -- Summary: ConsoleProducer uses deprecated BaseProducer Key: KAFKA-5529 URL: https://issues.apache.org/jira/browse/KAFKA-5529 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:35 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:35 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:34 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:33 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:33 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:32 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:31 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:31 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:30 AM:

[jira] [Comment Edited] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5167 at 6/28/17 7:29 AM:

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066045#comment-16066045 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5167: --- Hi, I think I foun