[jira] [Created] (KAFKA-5683) Dedicated thread pool for Kafka Streams tasks

Abhishek Gupta created KAFKA-5683: - Summary: Dedicated thread pool for Kafka Streams tasks Key: KAFKA-5683 URL: https://issues.apache.org/jira/browse/KAFKA-5683 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108328#comment-16108328 ] Ewen Cheslack-Postava commented on KAFKA-2526: -- What is the proposed fix? I don't know that

[jira] [Commented] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

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

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108156#comment-16108156 ] Jiangjie Qin commented on KAFKA-5621: - [~ijuma] Like [~apurva] said, for users who care about orders,

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108155#comment-16108155 ] Ismael Juma commented on KAFKA-5621: [~apurva], if the producer is blocked for more than max.block.ms

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108141#comment-16108141 ] Apurva Mehta commented on KAFKA-5621: - [~ijuma], can't speak for [~becket_qin], but it seems that the

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108130#comment-16108130 ] Ismael Juma commented on KAFKA-5621: [~becket_qin], you said a couple of times that if delivery can't

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108095#comment-16108095 ] Jason Gustafson commented on KAFKA-5621: Interesting discussion. Apurva's suggestion on a

[jira] [Commented] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

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

[jira] [Resolved] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5671. -- Resolution: Fixed Issue resolved by pull request 3602

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108067#comment-16108067 ] Apurva Mehta commented on KAFKA-5621: - [~becket_qin] shall we then post kip-91 to the community list

[jira] [Comment Edited] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108067#comment-16108067 ] Apurva Mehta edited comment on KAFKA-5621 at 7/31/17 10:15 PM: ---

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108050#comment-16108050 ] Jiangjie Qin commented on KAFKA-5621: - [~apurva] Thanks for the explanation. I think we are on the

[jira] [Commented] (KAFKA-5638) Inconsistency in consumer group related ACLs

[ https://issues.apache.org/jira/browse/KAFKA-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108007#comment-16108007 ] Jason Gustafson commented on KAFKA-5638: [~vahid] Interesting point. Maybe we could just extend

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107971#comment-16107971 ] Apurva Mehta commented on KAFKA-5621: - Thanks for your comment Becket, and sorry for the delay in

[jira] [Comment Edited] (KAFKA-960) Upgrade Metrics to 3.x

[ https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107720#comment-16107720 ] Gennady Feldman edited comment on KAFKA-960 at 7/31/17 9:04 PM: Latest

[jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107857#comment-16107857 ] James Cheng edited comment on KAFKA-1120 at 7/31/17 7:53 PM: - [~noslowerdna]

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107857#comment-16107857 ] James Cheng commented on KAFKA-1120: Hi, I retested this will Kafka 0.11. The problem still exists.

[jira] [Created] (KAFKA-5681) jarAll does not build all scala versions anymore.

Jiangjie Qin created KAFKA-5681: --- Summary: jarAll does not build all scala versions anymore. Key: KAFKA-5681 URL: https://issues.apache.org/jira/browse/KAFKA-5681 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107727#comment-16107727 ] Dan Collins commented on KAFKA-5505: Hi, I wanted to add on to this given we are working around the

[jira] [Commented] (KAFKA-1944) Rename LogCleaner and related classes to LogCompactor

[ https://issues.apache.org/jira/browse/KAFKA-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107678#comment-16107678 ] Ismael Juma commented on KAFKA-1944: By the way, we should also consider whether this change is worth

[jira] [Assigned] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5676: Assignee: Chanchal Singh > MockStreamsMetrics should be in o.a.k.test >

[jira] [Commented] (KAFKA-5677) Remove deprecated punctuate method

[ https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107662#comment-16107662 ] Guozhang Wang commented on KAFKA-5677: -- I think we should not remove test coverage as long as the

[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=16107653#comment-16107653 ] Guozhang Wang commented on KAFKA-5233: -- I agree with both of your regarding keeping the unit tests

[jira] [Assigned] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5621: --- Assignee: Apurva Mehta > The producer should retry expired batches when retries are enabled

[jira] [Commented] (KAFKA-5674) max.connections.per.ip minimum value to be zero to allow IP address blocking

[ https://issues.apache.org/jira/browse/KAFKA-5674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107570#comment-16107570 ] Viktor Somogyi commented on KAFKA-5674: --- [~tmgstev], I'd assign this to myself if you don't mind or

[jira] [Commented] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107569#comment-16107569 ] Jiangjie Qin commented on KAFKA-5678: - [~Json Tu] [~cuiyang] In DelayedProduce.tryComplete(), it will

[jira] [Commented] (KAFKA-1944) Rename LogCleaner and related classes to LogCompactor

[ https://issues.apache.org/jira/browse/KAFKA-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107346#comment-16107346 ] Pranav Maniar commented on KAFKA-1944: -- Thanks [~becket_qin] , I will go through wiki page and try to

[jira] [Assigned] (KAFKA-5653) Add new API methods to KTable

[ https://issues.apache.org/jira/browse/KAFKA-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5653: - Assignee: Damian Guy > Add new API methods to KTable > - > >

[jira] [Assigned] (KAFKA-5655) Add new API methods to KGroupedTable

[ https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5655: - Assignee: Damian Guy > Add new API methods to KGroupedTable >

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107288#comment-16107288 ] cuiyang edited comment on KAFKA-5678 at 7/31/17 1:14 PM: - Unfortunately, this

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107288#comment-16107288 ] cuiyang edited comment on KAFKA-5678 at 7/31/17 1:13 PM: - Unfortunately, this

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107288#comment-16107288 ] cuiyang edited comment on KAFKA-5678 at 7/31/17 1:12 PM: - Unfortunately, this

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107288#comment-16107288 ] cuiyang edited comment on KAFKA-5678 at 7/31/17 1:11 PM: - Unfortunately, this

[jira] [Commented] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107288#comment-16107288 ] cuiyang commented on KAFKA-5678: Unfortunately, this issue can still be reproduced on our Kafka cluster

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107162#comment-16107162 ] Chanchal Singh commented on KAFKA-5676: --- I am new to open source contribution and want to start with

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106965#comment-16106965 ] Dan commented on KAFKA-2729: Happened in 0.11.0.0 as well. Had to restart the broker to bring it back to

[jira] [Created] (KAFKA-5680) Don't materliaze physical state stores in KTable filter/map etc operations

Damian Guy created KAFKA-5680: - Summary: Don't materliaze physical state stores in KTable filter/map etc operations Key: KAFKA-5680 URL: https://issues.apache.org/jira/browse/KAFKA-5680 Project: Kafka