[jira] [Commented] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16110287#comment-16110287 ] Sanjoy Dasgupta commented on KAFKA-5690: Here is the crux of the requirement, once

[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&focusedCommentId=16110265#comment-16110265 ] cuiyang edited comment on KAFKA-5678 at 8/2/17 4:15 AM: [~becket_q

[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&focusedCommentId=16110265#comment-16110265 ] cuiyang edited comment on KAFKA-5678 at 8/2/17 4:14 AM: [~becket_q

[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&focusedCommentId=16110265#comment-16110265 ] cuiyang edited comment on KAFKA-5678 at 8/2/17 4:14 AM: [~becket_q

[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&focusedCommentId=16110265#comment-16110265 ] cuiyang commented on KAFKA-5678: [~becket_qin] Thank you for your nice explanation . I ha

[jira] [Comment Edited] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16110080#comment-16110080 ] huxihx edited comment on KAFKA-5690 at 8/2/17 3:38 AM: --- I am seeing

[jira] [Commented] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH

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

[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&focusedCommentId=16110205#comment-16110205 ] Onur Karaman commented on KAFKA-1120: - Thanks [~wushujames] that is perfect. I can rep

[jira] [Created] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH

Ryan P created KAFKA-5691: - Summary: ZKUtils.CreateRecursive should handle NOAUTH Key: KAFKA-5691 URL: https://issues.apache.org/jira/browse/KAFKA-5691 Project: Kafka Issue Type: Bug Repo

[jira] [Commented] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16110080#comment-16110080 ] huxihx commented on KAFKA-5690: --- I am seeing this jira as an improvement instead of a bug si

[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&focusedCommentId=16110075#comment-16110075 ] Jiangjie Qin commented on KAFKA-5678: - [~guozhang] Likely KAFKA- should solve the

[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&focusedCommentId=16110038#comment-16110038 ] Guozhang Wang commented on KAFKA-5678: -- Sorry for being late on the discussion, just

[jira] [Commented] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup

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

[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&focusedCommentId=16110002#comment-16110002 ] James Cheng commented on KAFKA-1120: [~onurkaraman], try this? I made it as copy/paste

[jira] [Commented] (KAFKA-3623) Make KStreamTestDriver extending from ExternalResource

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

[jira] [Commented] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109937#comment-16109937 ] Sanjoy Dasgupta commented on KAFKA-5690: Yes, this will be really useful. If I cre

[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&focusedCommentId=16109910#comment-16109910 ] Jiangjie Qin edited comment on KAFKA-5678 at 8/1/17 10:34 PM: --

[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&focusedCommentId=16109910#comment-16109910 ] Jiangjie Qin commented on KAFKA-5678: - That's right. I was under the impression that K

[jira] [Created] (KAFKA-5690) kafka-acls command should be able to list per principal

Koelli Mungee created KAFKA-5690: Summary: kafka-acls command should be able to list per principal Key: KAFKA-5690 URL: https://issues.apache.org/jira/browse/KAFKA-5690 Project: Kafka Issue T

[jira] [Comment Edited] (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&focusedCommentId=16109479#comment-16109479 ] Vahid Hashemian edited comment on KAFKA-5638 at 8/1/17 6:38 PM:

[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&focusedCommentId=16109479#comment-16109479 ] Vahid Hashemian commented on KAFKA-5638: [~hachikuji] That should work too, and gi

[jira] [Commented] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

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

[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&focusedCommentId=16109435#comment-16109435 ] Guozhang Wang commented on KAFKA-5676: -- If you take a look at all unit test classes t

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109419#comment-16109419 ] Fernando Vega commented on KAFKA-5407: -- [~huxi_2b] Do you have any suggestion. > Mi

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109412#comment-16109412 ] Guozhang Wang commented on KAFKA-5684: -- Thanks for filing the JIRA. I think we made

[jira] [Created] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store

Damian Guy created KAFKA-5689: - Summary: Refactor WindowStore hierarchy so that Metered Store is the outermost store Key: KAFKA-5689 URL: https://issues.apache.org/jira/browse/KAFKA-5689 Project: Kafka

[jira] [Updated] (KAFKA-5652) Add new api methods to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5652: -- Component/s: streams > Add new api methods to KStream > -- > >

[jira] [Updated] (KAFKA-5673) Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store

[ https://issues.apache.org/jira/browse/KAFKA-5673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5673: -- Component/s: streams > Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the > outermost

[jira] [Updated] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

[ https://issues.apache.org/jira/browse/KAFKA-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5651: -- Component/s: streams > KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage > e

[jira] [Updated] (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 updated KAFKA-5653: -- Component/s: streams > Add new API methods to KTable > - > >

[jira] [Updated] (KAFKA-5654) Add new API methods to KGroupedStream

[ https://issues.apache.org/jira/browse/KAFKA-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5654: -- Component/s: streams > Add new API methods to KGroupedStream > - > >

[jira] [Updated] (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 updated KAFKA-5655: -- Component/s: streams > Add new API methods to KGroupedTable > > >

[jira] [Assigned] (KAFKA-5668) queryable state window store range scan only returns results from one store

[ https://issues.apache.org/jira/browse/KAFKA-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5668: - Assignee: Damian Guy > queryable state window store range scan only returns results from one stor

[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&focusedCommentId=16109253#comment-16109253 ] Onur Karaman commented on KAFKA-1120: - Hi [~wushujames] can you provide a more precise

[jira] [Resolved] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5154. --- Resolution: Fixed > Kafka Streams throws NPE during rebalance > --

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

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

[jira] [Updated] (KAFKA-5687) Retention settings are inconsistent between broker and topic

[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Babrou updated KAFKA-5687: --- Attachment: screenshot-2.png > Retention settings are inconsistent between broker and topic >

[jira] [Commented] (KAFKA-5687) Retention settings are inconsistent between broker and topic

[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109114#comment-16109114 ] Ivan Babrou commented on KAFKA-5687: By "impossible" I mean "not documented". In the d

[jira] [Updated] (KAFKA-5687) Retention settings are inconsistent between broker and topic

[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Babrou updated KAFKA-5687: --- Attachment: screenshot-1.png > Retention settings are inconsistent between broker and topic >

[jira] [Commented] (KAFKA-5687) Retention settings are inconsistent between broker and topic

[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109076#comment-16109076 ] Ismael Juma commented on KAFKA-5687: What do you mean by "impossible". You are saying

[jira] [Created] (KAFKA-5688) Add a modifier to the REST endpoint to only show errors

Dustin Cote created KAFKA-5688: -- Summary: Add a modifier to the REST endpoint to only show errors Key: KAFKA-5688 URL: https://issues.apache.org/jira/browse/KAFKA-5688 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5687) Retention settings are inconsistent between broker and topic

Ivan Babrou created KAFKA-5687: -- Summary: Retention settings are inconsistent between broker and topic Key: KAFKA-5687 URL: https://issues.apache.org/jira/browse/KAFKA-5687 Project: Kafka Issue

[jira] [Commented] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement

[ https://issues.apache.org/jira/browse/KAFKA-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109019#comment-16109019 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4314: --- And here: http://ka

[jira] [Updated] (KAFKA-5672) Move measureLatencyNs from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5672: -- Labels: needs-kip (was: ) > Move measureLatencyNs from StreamsMetricsImpl to StreamsMetrics >

[jira] [Closed] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement

[ https://issues.apache.org/jira/browse/KAFKA-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4314. - > Kafka Streams documentation needs definitive rework and improvement > --

[jira] [Closed] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4312. - > void KTableImpl.writeAsText(String filePath) throws NullPointerException whe

[jira] [Closed] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4316. - > Kafka Streams 0.10.0.1 does not run on Windows x64 > ---

[jira] [Closed] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-4849. - > Bug in KafkaStreams documentation > - > >

[jira] [Closed] (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 closed KAFKA-5530. - Proper configuration was applied and Kafka went good. > Balancer is dancing w

[jira] [Commented] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement

[ https://issues.apache.org/jira/browse/KAFKA-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109002#comment-16109002 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4314: --- Kafka streams are n

[jira] [Resolved] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement

[ https://issues.apache.org/jira/browse/KAFKA-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-4314. --- Resolution: Done > Kafka Streams documentation needs definitive rework

[jira] [Updated] (KAFKA-5686) Documentation inconsistency on the "Compression"

[ https://issues.apache.org/jira/browse/KAFKA-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5686: -- Description: At the page: https://kafka.apache.org/documentation/ Ther

[jira] [Updated] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5684: -- Labels: (was: needs-kip) > KStreamPrintProcessor as customized KStreamPeekProcessor >

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108992#comment-16108992 ] Damian Guy commented on KAFKA-5684: --- Yep - sorry i missed that. You are right, this JIR

[jira] [Updated] (KAFKA-5686) Documentation inconsistency on the "Compression"

[ https://issues.apache.org/jira/browse/KAFKA-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5686: -- Description: At the page: https://kafka.apache.org/documentation/ Ther

[jira] [Updated] (KAFKA-5686) Documentation inconsistency on the "Compression"

[ https://issues.apache.org/jira/browse/KAFKA-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5686: -- Description: At the page: https://kafka.apache.org/documentation/ Ther

[jira] [Updated] (KAFKA-5686) Documentation inconsistency on the "Compression"

[ https://issues.apache.org/jira/browse/KAFKA-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5686: -- Description: At the page: https://kafka.apache.org/documentation/ Ther

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108984#comment-16108984 ] Paolo Patierno commented on KAFKA-5684: --- This JIRA won't change the API. It's just a

[jira] [Created] (KAFKA-5686) Documentation inconsistency on the "Compression"

Seweryn Habdank-Wojewodzki created KAFKA-5686: - Summary: Documentation inconsistency on the "Compression" Key: KAFKA-5686 URL: https://issues.apache.org/jira/browse/KAFKA-5686 Project: Kafk

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108963#comment-16108963 ] Damian Guy commented on KAFKA-5684: --- This would need a KIP as it is a public API change.

[jira] [Created] (KAFKA-5685) Interface of ReadOnlyKeyValueStore should provide a non blocking interface for stores with non blocking capabilities

Chris Wewerka created KAFKA-5685: Summary: Interface of ReadOnlyKeyValueStore should provide a non blocking interface for stores with non blocking capabilities Key: KAFKA-5685 URL: https://issues.apache.org/jira/b

[jira] [Updated] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5684: -- Labels: needs-kip (was: ) > KStreamPrintProcessor as customized KStreamPeekProcessor >

[jira] [Commented] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields

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

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108903#comment-16108903 ] Paolo Patierno commented on KAFKA-5684: --- [~damianguy] [~mjsax] [~bbejeck] what do yo

[jira] [Assigned] (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:all-tabpanel ] Viktor Somogyi reassigned KAFKA-5674: - Assignee: Viktor Somogyi > max.connections.per.ip minimum value to be zero to allow IP ad

[jira] [Created] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

Paolo Patierno created KAFKA-5684: - Summary: KStreamPrintProcessor as customized KStreamPeekProcessor Key: KAFKA-5684 URL: https://issues.apache.org/jira/browse/KAFKA-5684 Project: Kafka Issu

[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&focusedCommentId=16108836#comment-16108836 ] Ismael Juma commented on KAFKA-1944: I agree that we should probably deprecate and eve

[jira] [Commented] (KAFKA-5637) Document compatibility and release policies

[ https://issues.apache.org/jira/browse/KAFKA-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108724#comment-16108724 ] Tom Bentley commented on KAFKA-5637: I'd be interested to know what the expectation is

[jira] [Commented] (KAFKA-5547) Return topic authorization failed if no topic describe access

[ https://issues.apache.org/jira/browse/KAFKA-5547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108674#comment-16108674 ] huxihx commented on KAFKA-5547: --- [~hachikuji] A quick question please. Why does the check 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&focusedCommentId=16108605#comment-16108605 ] tuyang commented on KAFKA-5678: --- [~becket_qin] I patched the pull request，and the problem d

[jira] [Commented] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests

[ https://issues.apache.org/jira/browse/KAFKA-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108573#comment-16108573 ] Paolo Patierno commented on KAFKA-5643: --- Any committers that can take a look to this

[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&focusedCommentId=16108543#comment-16108543 ] Ismael Juma commented on KAFKA-1120: I tentatively assigned this to 1.0.0 so that we i

[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&focusedCommentId=16078619#comment-16078619 ] Ismael Juma edited comment on KAFKA-1120 at 8/1/17 7:58 AM: [~

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

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1120: --- Fix Version/s: 1.0.0 > Controller could miss a broker state change >

[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&focusedCommentId=16108489#comment-16108489 ] Chanchal Singh commented on KAFKA-5676: --- I have changed package for class . I am exp

[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&focusedCommentId=16108490#comment-16108490 ] Chanchal Singh commented on KAFKA-5676: --- I have modified package for class and worki

[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&focusedCommentId=16108485#comment-16108485 ] Tristan Stevens commented on KAFKA-5674: [~viktorsomogyi] If you're happy to pick