[jira] [Commented] (KAFKA-1368) Upgrade log4j

2018-03-12 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394956#comment-16394956 ] Gérald Quintana commented on KAFKA-1368: How is this related to

[jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395002#comment-16395002 ] ASF GitHub Bot commented on KAFKA-4493: --- taku-k closed pull request #2408: KAFKA-4493: Validate a

[jira] [Commented] (KAFKA-6317) Maven artifact for kafka should not depend on log4j

2018-03-12 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-6317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394958#comment-16394958 ] Gérald Quintana commented on KAFKA-6317: Does that mean that we can replace Log4J1 by Log4J2 ou

[jira] [Commented] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

2018-03-12 Thread Abhishek Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395095#comment-16395095 ] Abhishek Agarwal commented on KAFKA-6556: - I am working on something similar (currently for

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2018-03-12 Thread Filipe Agapito (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395070#comment-16395070 ] Filipe Agapito commented on KAFKA-6474: --- Hi John, So far I've done most of the refactor and I

[jira] [Created] (KAFKA-6636) ReplicaFetcherThread should not die if hw < 0

2018-03-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6636: --- Summary: ReplicaFetcherThread should not die if hw < 0 Key: KAFKA-6636 URL: https://issues.apache.org/jira/browse/KAFKA-6636 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-6624: --- Assignee: Dong Lin > log segment deletion could cause a disk to be marked offline incorrectly >

[jira] [Created] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start

2018-03-12 Thread Chong Wang (JIRA)
Chong Wang created KAFKA-6637: - Summary: if set topic config segment.ms=0 Kafka broker won't be able to start Key: KAFKA-6637 URL: https://issues.apache.org/jira/browse/KAFKA-6637 Project: Kafka

[jira] [Updated] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start

2018-03-12 Thread Chong Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chong Wang updated KAFKA-6637: -- Affects Version/s: 1.0.0 > if set topic config segment.ms=0 Kafka broker won't be able to start >

[jira] [Resolved] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker

2018-03-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6337. -- Resolution: Cannot Reproduce Please reopen if you think the issue still exists > Error for partition

[jira] [Resolved] (KAFKA-5504) Kafka controller is not getting elected

2018-03-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5504. -- Resolution: Not A Problem Closing as per above comments. > Kafka controller is not getting elected >

[jira] [Resolved] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

2018-03-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4984. -- Resolution: Cannot Reproduce {color:#00}Closing inactive issue. Please reopen if you think the

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395807#comment-16395807 ] ASF GitHub Bot commented on KAFKA-6560: --- guozhangwang closed pull request #4685: KAFKA-6560: Add

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

2018-03-12 Thread Jonathan Skrzypek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395521#comment-16395521 ] Jonathan Skrzypek commented on KAFKA-6195: -- updated the KIP, thoughts ? > DNS alias support for

[jira] [Resolved] (KAFKA-5467) setting offset retention minutes to a lower value is not reflecting

2018-03-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5467. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen if you think the issue exists. >

[jira] [Resolved] (KAFKA-6022) mirror maker stores offset in zookeeper

2018-03-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6022. -- Resolution: Not A Problem Please reopen if you think the issue still exists > mirror maker stores

[jira] [Commented] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396554#comment-16396554 ] ASF GitHub Bot commented on KAFKA-6624: --- junrao closed pull request #4663: KAFKA-6624; Prevent

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-03-12 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396531#comment-16396531 ] Ashish Surana commented on KAFKA-6555: -- +1. Let me capture all the approaches in KIP, and we can have

[jira] [Resolved] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly

2018-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-6624. Resolution: Fixed Fix Version/s: 1.1.0 > log segment deletion could cause a disk to be marked

[jira] [Created] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time

2018-03-12 Thread Navinder Brar (JIRA)
Navinder Brar created KAFKA-6643: Summary: Warm up new replicas from scratch when changelog topic has retention time Key: KAFKA-6643 URL: https://issues.apache.org/jira/browse/KAFKA-6643 Project:

[jira] [Resolved] (KAFKA-3368) Add the Message/Record set protocol to the protocol docs

2018-03-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3368. Resolution: Fixed Fix Version/s: 1.2.0 > Add the Message/Record set protocol to the

[jira] [Created] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6640: --- Summary: Improve efficiency of KafkaAdminClient.describeTopics() Key: KAFKA-6640 URL: https://issues.apache.org/jira/browse/KAFKA-6640 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-6638) Leader should remove unassigned replica from ISR

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6638: Summary: Leader should remove unassigned replica from ISR (was: Controller should remove replica from ISR

[jira] [Created] (KAFKA-6642) Rack aware replica assignment in kafka streams

2018-03-12 Thread Ashish Surana (JIRA)
Ashish Surana created KAFKA-6642: Summary: Rack aware replica assignment in kafka streams Key: KAFKA-6642 URL: https://issues.apache.org/jira/browse/KAFKA-6642 Project: Kafka Issue Type: New

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time

2018-03-12 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-6643: - Description: In the current scenario, Kafka Streams has changelog Kafka topics(internal topics

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time

2018-03-12 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-6643: - Summary: Warm up new replicas from scratch when changelog topic has LIMITED retention time (was:

[jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time

2018-03-12 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-6643: - Description: In the current scenario, Kafka Streams has changelog Kafka topics(internal topics

[jira] [Commented] (KAFKA-5540) Deprecate and remove internal converter configs

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396134#comment-16396134 ] ASF GitHub Bot commented on KAFKA-5540: --- C0urante opened a new pull request #4693: KAFKA-5540:

[jira] [Updated] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6640: Description: Currently in KafkaAdminClient.describeTopics(), for each topic in the request, an complete map

[jira] [Updated] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6640: Description: Currently in KafkaAdminClient.describeTopics(), for each topic in the request, an complete map

[jira] [Updated] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6640: Description: Currently in KafkaAdminClient.describeTopics(), for each topic in the request, an complete map

[jira] [Created] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

2018-03-12 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6641: Summary: Consider auto repartitioning for Stream.transform() API Key: KAFKA-6641 URL: https://issues.apache.org/jira/browse/KAFKA-6641 Project: Kafka Issue

[jira] [Assigned] (KAFKA-4831) Extract WindowedSerde to public APIs

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4831: Resolution: Fixed Assignee: Guozhang Wang (was: Vitaly Pushkar) Fix

[jira] [Created] (KAFKA-6639) Follower may have sparse index if catching up

2018-03-12 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6639: -- Summary: Follower may have sparse index if catching up Key: KAFKA-6639 URL: https://issues.apache.org/jira/browse/KAFKA-6639 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396241#comment-16396241 ] ASF GitHub Bot commented on KAFKA-6640: --- lindong28 opened a new pull request #4694: KAFKA-6640;

[jira] [Updated] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6641: - Labels: api (was: ) > Consider auto repartitioning for Stream.transform() API >

[jira] [Updated] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6640: Description: Currently in KafkaAdminClient.describeTopics(), for each topic in the request, an complete map

[jira] [Updated] (KAFKA-6638) Leader should remove unassigned replica from ISR

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6638: Description: During partition reassignment, controller may remove a replica from the replica set while

[jira] [Commented] (KAFKA-6638) Leader should remove unassigned replica from ISR

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396325#comment-16396325 ] ASF GitHub Bot commented on KAFKA-6638: --- lindong28 opened a new pull request #4696: KAFKA-6638;

[jira] [Commented] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396307#comment-16396307 ] Guozhang Wang commented on KAFKA-6631: -- If you are certain that I do not see the error complaining

[jira] [Created] (KAFKA-6638) Controller should remove replica from ISR if the replica is removed from the replica set

2018-03-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6638: --- Summary: Controller should remove replica from ISR if the replica is removed from the replica set Key: KAFKA-6638 URL: https://issues.apache.org/jira/browse/KAFKA-6638

[jira] [Updated] (KAFKA-6636) ReplicaFetcherThread should not die if hw < 0

2018-03-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6636: Description: ReplicaFetcherThread can die in the following scenario:   1) Partition P1 has replica set

[jira] [Updated] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6535: - Summary: Set default retention ms for Streams repartition topics to Long.MAX_VALUE (was: Set

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395884#comment-16395884 ] Guozhang Wang commented on KAFKA-6535: -- Makes sense, I've changed the title accordingly. And also

[jira] [Updated] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-03-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6535: - Description: After KIP-220 / KIP-204, repartition topics in Streams are transient, so it is