Re: [DISCUSS] KIP-217: Expose a timeout to allow an expired ZK session to be re-created

2017-10-28 Thread Stephane Maarek
Hi Jun, I think this is very helpful. Restarting Kafka brokers in case of zookeeper host change is not a well known operation. Few questions: 1) would it not be worth fixing the problem at the source ? This has been stuck for a while though, maybe a little push would help : https://issues.apache.

Re: [VOTE] KIP-214: Add zookeeper.max.in.flight.requests config to the broker

2017-10-28 Thread Manikumar
+1 (non-binding) On Fri, Oct 27, 2017 at 10:46 PM, Ted Yu wrote: > +1 > > On Fri, Oct 27, 2017 at 10:15 AM, Onur Karaman < > onurkaraman.apa...@gmail.com > > wrote: > > > I'd like to start the vote for KIP-214: Add > > zookeeper.max.in.flight.requests config to the broker > > > > https://cwiki.a

[jira] [Resolved] (KAFKA-6019) Sentry permissions bug on CDH

2017-10-28 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6019. -- Resolution: Duplicate > Sentry permissions bug on CDH > - > >

[GitHub] kafka pull request #4155: KAFKA-5645: Use async ZookeeperClient in SimpleAcl...

2017-10-28 Thread omkreddy
GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/4155 KAFKA-5645: Use async ZookeeperClient in SimpleAclAuthorizer You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka KAFKA-5645-ZK-AUTH

[jira] [Resolved] (KAFKA-6061) "ERROR Error while electing or becoming leader on broker 13 (kafka.server.ZookeeperLeaderElector) kafka.common.KafkaException: Can't parse json string: null" should pri

2017-10-28 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-6061. --- Resolution: Duplicate Fix Version/s: (was: 1.1.0) > "ERROR Error while electing or

[jira] [Resolved] (KAFKA-3860) No broker partitions consumed by consumer thread

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3860. Resolution: Auto Closed The old consumer is no longer supported, please upgrade to the Java consumer

[jira] [Resolved] (KAFKA-3756) javadoc has issues with incorrect @param, @throws, @return

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3756. Resolution: Auto Closed Closing as 0.8.2 branch is no longer supported. > javadoc has issues with i

[jira] [Resolved] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3917. Resolution: Duplicate This log cleaner issue has been fixed in more recent versions. I suggest upgr

[jira] [Resolved] (KAFKA-4096) Kafka Backup and Recovery

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4096. Resolution: Auto Closed Thanks for the JIRA. This should work. If you are still seeing this with a m

[GitHub] kafka pull request #4154: KAFKA-4203: Align broker default for max.message.b...

2017-10-28 Thread ijuma
GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4154 KAFKA-4203: Align broker default for max.message.bytes with Java producer default You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka ka

[jira] [Resolved] (KAFKA-4832) kafka producer send Async message to the wrong IP cannot to stop producer.close()

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4832. Resolution: Auto Closed The Scala producers have been deprecated for a while and no further work is

[jira] [Resolved] (KAFKA-5963) Null Pointer Exception on server

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5963. Resolution: Auto Closed Thanks for the JIRA. Kafka 0.8.x is no longer supported and the issue has mo

[jira] [Resolved] (KAFKA-5981) Update the affected versions on bug KAFKA-1194

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5981. Resolution: Duplicate Updated the fix versions. Only included the ones that are still supported. >

[jira] [Resolved] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6043. Resolution: Auto Closed The old consumer is deprecated and no further changes are planned. Please u

[jira] [Resolved] (KAFKA-6117) One Broker down can't rejoin the cluster

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6117. Resolution: Auto Closed Thanks for the JIRA. 0.8.2.x is unsupported at this point. Newer releases ha

[jira] [Resolved] (KAFKA-5934) Cross build for scala 2.12

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5934. Resolution: Won't Fix Thanks for the JIRA and PR. 0.8.x is unsupported at this point and we don't i

[jira] [Resolved] (KAFKA-2156) Possibility to plug in custom MetricRegistry

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2156. Resolution: Auto Closed It's unlikely that we will do this for Yammer Metrics. Please file a separat

[jira] [Resolved] (KAFKA-2180) topics never create on brokers though it succeeds in tool and is in zookeeper

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2180. Resolution: Auto Closed Not enough information and very old so auto closing. > topics never create

[jira] [Resolved] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-. Resolution: Won't Fix The code changed dramatically since this was filed (the stacktrace doesn't eve

[jira] [Resolved] (KAFKA-6064) Cluster hung when the controller tried to delete a bunch of topics

2017-10-28 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6064. Resolution: Auto Closed 0.8.2.1 is no longer supported. Many bugs related to topic deletion have bee

Re: [VOTE] KIP-205: Add all() and range() API to ReadOnlyWindowStore

2017-10-28 Thread Bill Bejeck
+1 for the KIP and +1 on renaming "range" to "fetchAll" Thanks, Bill On Thu, Oct 26, 2017 at 4:39 PM, Guozhang Wang wrote: > BTW, Xavier has an argument to rename "range" as it does not take a key or > key range at all. I'd propose we rename this function to "fetchAll". > > Guozhang > > On Wed,

[GitHub] kafka pull request #4149: KAFKA-6126: Reduce rebalance time by not checking ...

2017-10-28 Thread jeyhunkarimov
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/4149 ---

Re: Errors when running integration/kafka/tools/MirrorMakerIntegrationTest

2017-10-28 Thread Pavel Drankov
Hi, I have just created a issue: KAFKA-6141 and related PR for that. Can someone review it? Best wishes, Pavel On 27 October 2017 at 19:24, Pavel Drankov wrote: > Yes, I m interested and would like to make a PR. > > Best wishes, > Pavel > > On 27 October 2017 at 19:05, Ismael Juma wrote: > >>

[jira] [Resolved] (KAFKA-6140) When running tests on kafka then such logs apper:

2017-10-28 Thread Pavel (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pavel resolved KAFKA-6140. -- Resolution: Duplicate Duplicate of KAFKA-6141 > When running tests on kafka then such logs apper: > ---

[GitHub] kafka pull request #4153: KAFKA-6141: add disabling of useless embedded zook...

2017-10-28 Thread Sammers21
GitHub user Sammers21 opened a pull request: https://github.com/apache/kafka/pull/4153 KAFKA-6141: add disabling of useless embedded zookeeper error logs Created a function which sets `zkShutdownHandler` filed of a `ZooKeeperServer` object via reflection(because it field and `ZooK

[jira] [Created] (KAFKA-6141) Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest

2017-10-28 Thread Pavel (JIRA)
Pavel created KAFKA-6141: Summary: Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest Key: KAFKA-6141 URL: https://issues.apache.org/jira/browse/KAFKA-6141 Project: Kafka Is

[jira] [Created] (KAFKA-6140) When running tests on kafka then such logs apper:

2017-10-28 Thread Pavel (JIRA)
Pavel created KAFKA-6140: Summary: When running tests on kafka then such logs apper: Key: KAFKA-6140 URL: https://issues.apache.org/jira/browse/KAFKA-6140 Project: Kafka Issue Type: Improvement

[GitHub] kafka pull request #4152: MINOR: Eliminate unnecessary Topic(And)Partition a...

2017-10-28 Thread ijuma
GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4152 MINOR: Eliminate unnecessary Topic(And)Partition allocations in Controller - Eliminated all the unnecessary allocations of `TopicPartition` and `TopicAndPartition` in the Controller. We now use the