Re: [VOTE] KIP-164 Add unavailablePartitionCount and per-partition Unavailable metrics

Seems pretty small and simple and I don't have anything for this release yet, so I'll pick it up. We can rebalance as we near release date if necessary. Guozhang, I also notice that a bunch of JIRAs in that release wiki aren't marked for 1.0.0 yet and aren't blockers. Since you're release mgr

Jenkins build is back to normal : kafka-trunk-jdk8 #1854

See

[GitHub] kafka pull request #3586: KAFKA-5665: Heartbeat thread should use correct in...

GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3586 KAFKA-5665: Heartbeat thread should use correct interruption method to restore status When interrupting the background heartbeat thread, `Thread.interrupted();` is used. Actually,

[jira] [Created] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread

huxihx created KAFKA-5665: - Summary: Incorrect interruption invoking method used for Heartbeat thread Key: KAFKA-5665 URL: https://issues.apache.org/jira/browse/KAFKA-5665 Project: Kafka Issue

Build failed in Jenkins: kafka-trunk-jdk8 #1853

See Changes: [wangguoz] MINOR: updated configs to use one try/catch for serdes -- [...truncated 923.91 KB...] kafka.api.PlaintextProducerSendTest >

[jira] [Created] (KAFKA-5664) Disable auto offset commit in ConsoleConsumer if no group is provided

Jason Gustafson created KAFKA-5664: -- Summary: Disable auto offset commit in ConsoleConsumer if no group is provided Key: KAFKA-5664 URL: https://issues.apache.org/jira/browse/KAFKA-5664 Project:

[jira] [Created] (KAFKA-5663) LogDirFailureTest system test fails

Apurva Mehta created KAFKA-5663: --- Summary: LogDirFailureTest system test fails Key: KAFKA-5663 URL: https://issues.apache.org/jira/browse/KAFKA-5663 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5662) We should be able to specify min.insync.replicas for the __consumer_offsets topic

Apurva Mehta created KAFKA-5662: --- Summary: We should be able to specify min.insync.replicas for the __consumer_offsets topic Key: KAFKA-5662 URL: https://issues.apache.org/jira/browse/KAFKA-5662

[jira] [Created] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance

Apurva Mehta created KAFKA-5661: --- Summary: Develop and understanding of how to tune transactions for optimal performance Key: KAFKA-5661 URL: https://issues.apache.org/jira/browse/KAFKA-5661 Project:

[jira] [Created] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

Matthias J. Sax created KAFKA-5660: -- Summary: Don't throw TopologyBuilderException during runtime Key: KAFKA-5660 URL: https://issues.apache.org/jira/browse/KAFKA-5660 Project: Kafka Issue

[GitHub] kafka pull request #3585: KAFKA-5659. AdminClient#describeConfigs makes an e...

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/3585 KAFKA-5659. AdminClient#describeConfigs makes an extra empty request … …when only broker info is requested You can merge this pull request into a Git repository by running: $ git pull

Jenkins build is back to normal : kafka-trunk-jdk7 #2578

See

[jira] [Created] (KAFKA-5659) AdminClient#describeConfigs makes an extra empty request when only broker info is requested

Colin P. McCabe created KAFKA-5659: -- Summary: AdminClient#describeConfigs makes an extra empty request when only broker info is requested Key: KAFKA-5659 URL: https://issues.apache.org/jira/browse/KAFKA-5659

[GitHub] kafka pull request #3584: KAFKA-5658. Fix AdminClient request timeout handli...

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/3584 KAFKA-5658. Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions The AdminClient does not properly clear calls from the callsInFlight structure. Later,

[jira] [Created] (KAFKA-5658) adminclient will stop working after some amount of time

dan norwood created KAFKA-5658: -- Summary: adminclient will stop working after some amount of time Key: KAFKA-5658 URL: https://issues.apache.org/jira/browse/KAFKA-5658 Project: Kafka Issue

Re: [VOTE] KIP-164 Add unavailablePartitionCount and per-partition Unavailable metrics

Hello, I would like to call out someone (committer) to voluntarily shepherd this KIP and drive it to be merged for 1.0.0. Please feel free to add your name on KIP-164 on the release wiki page: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=71764913 Guozhang On Wed, Jul 26,

[GitHub] kafka pull request #3580: MINOR: Next release will be 1.0.0

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3580 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3568: MINOR: updated configs to use one try/catch for se...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3568 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

Randall Hauch created KAFKA-5657: Summary: Connect REST API should include the connector type when describing a connector Key: KAFKA-5657 URL: https://issues.apache.org/jira/browse/KAFKA-5657

Build failed in Jenkins: kafka-trunk-jdk7 #2577

See Changes: [me] MINOR: Fix typo in SMT doc: s/RegexpRouter/RegexRouter -- [...truncated 1007.63 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Re: [DISCUSS] KIP-180: Add a broker metric specifying the number of consumer group rebalances in progress

To me `PreparingRebalance` sounds better than `StartingRebalance` since only by the end of that stage we have formed a new group. More specifically, this this the workflow from the coordinator's point of view: 1. decided to trigger a rebalance, enter PreparingRebalance phase; |

Re: [VOTE] KIP-167 (Addendum): Add interface for the state store restoration process

The re-vote has now passed. The votes where: Binding +1: Sriram, Guozhang, Damian Non-binding +1: Matthias. The discussion wrapping up in this PR https://github.com/apache/kafka/pull/3325 -Bill On Wed, Jul 26, 2017 at 10:10 AM, Damian Guy wrote: > +1 > > On Tue, 25 Jul

Build failed in Jenkins: kafka-trunk-jdk7 #2576

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

Build failed in Jenkins: kafka-trunk-jdk8 #1852

See Changes: [me] MINOR: Fix typo in SMT doc: s/RegexpRouter/RegexRouter -- [...truncated 2.54 MB...] org.apache.kafka.streams.integration.RegexSourceIntegrationTest >

[GitHub] kafka pull request #3583: KAFKA-5341; Add UnderMinIsrPartitionCount and per-...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/3583 KAFKA-5341; Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics (KIP-164) You can merge this pull request into a Git repository by running: $ git pull

Re: [VOTE] KIP-164 Add unavailablePartitionCount and per-partition Unavailable metrics

Thank you all for your vote! This KIP has been accepted with 3 binding votes (Ismael, Becket and Joel) and 4 non-binding votes (Mickael, Michal, Edoardo and Bill). On Tue, Jul 25, 2017 at 9:07 PM, Joel Koshy wrote: > +1 > > On Thu, Jul 20, 2017 at 10:30 AM, Becket Qin

[GitHub] kafka pull request #3582: KAFKA-5656: Support bulk attributes request on Kaf...

GitHub user ErikKringen opened a pull request: https://github.com/apache/kafka/pull/3582 KAFKA-5656: Support bulk attributes request on KafkaMbean where some Support bulk attributes request on KafkaMbean where some attributes do not exist You can merge this pull request into a

Build failed in Jenkins: kafka-trunk-jdk7 #2575

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

Build failed in Jenkins: kafka-trunk-jdk7 #2574

See -- Started by an SCM change Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[GitHub] kafka pull request #3576: Fix typo in SMT doc : s/RegexpRouter/RegexRouter

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3576 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (KAFKA-5656) Support bulk attributes request on KafkaMbean where some attributes do not exist

Erik Kringen created KAFKA-5656: --- Summary: Support bulk attributes request on KafkaMbean where some attributes do not exist Key: KAFKA-5656 URL: https://issues.apache.org/jira/browse/KAFKA-5656

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

Damian Guy created KAFKA-5655: - Summary: Add new API methods to KGroupedTable Key: KAFKA-5655 URL: https://issues.apache.org/jira/browse/KAFKA-5655 Project: Kafka Issue Type: Sub-task

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

Damian Guy created KAFKA-5653: - Summary: Add new API methods to KTable Key: KAFKA-5653 URL: https://issues.apache.org/jira/browse/KAFKA-5653 Project: Kafka Issue Type: Sub-task

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

Damian Guy created KAFKA-5654: - Summary: Add new API methods to KGroupedStream Key: KAFKA-5654 URL: https://issues.apache.org/jira/browse/KAFKA-5654 Project: Kafka Issue Type: Sub-task

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

Damian Guy created KAFKA-5652: - Summary: Add new api methods to KStream Key: KAFKA-5652 URL: https://issues.apache.org/jira/browse/KAFKA-5652 Project: Kafka Issue Type: Sub-task

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

Damian Guy created KAFKA-5651: - Summary: KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines Key: KAFKA-5651 URL: https://issues.apache.org/jira/browse/KAFKA-5651

[jira] [Created] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

Damian Guy created KAFKA-5650: - Summary: Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182) Key: KAFKA-5650 URL: https://issues.apache.org/jira/browse/KAFKA-5650

[jira] [Created] (KAFKA-5649) Producer is being closed generating ssl exception

Pablo Panero created KAFKA-5649: --- Summary: Producer is being closed generating ssl exception Key: KAFKA-5649 URL: https://issues.apache.org/jira/browse/KAFKA-5649 Project: Kafka Issue Type:

[GitHub] kafka pull request #3581: make Merger extend Aggregator

GitHub user cvaliente opened a pull request: https://github.com/apache/kafka/pull/3581 make Merger extend Aggregator I suggest that Merger should extend Aggregator. reason: Both classes usually do very similar things. A merger takes two sessions and combines

[jira] [Created] (KAFKA-5648) make Merger extend Aggregator

Clemens Valiente created KAFKA-5648: --- Summary: make Merger extend Aggregator Key: KAFKA-5648 URL: https://issues.apache.org/jira/browse/KAFKA-5648 Project: Kafka Issue Type: New Feature

[GitHub] kafka pull request #2214: KAFKA-1595; remove global lock from json parser

Github user resetius closed the pull request at: https://github.com/apache/kafka/pull/2214 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (KAFKA-5647) Use async ZookeeperClient for Admin operations

Ismael Juma created KAFKA-5647: -- Summary: Use async ZookeeperClient for Admin operations Key: KAFKA-5647 URL: https://issues.apache.org/jira/browse/KAFKA-5647 Project: Kafka Issue Type:

[GitHub] kafka pull request #2213: KAFKA-3038; Future'based pseudo-async controller

Github user resetius closed the pull request at: https://github.com/apache/kafka/pull/2213 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (KAFKA-5646) Use async ZookeeperClient for Config and ISR management

Ismael Juma created KAFKA-5646: -- Summary: Use async ZookeeperClient for Config and ISR management Key: KAFKA-5646 URL: https://issues.apache.org/jira/browse/KAFKA-5646 Project: Kafka Issue

[jira] [Created] (KAFKA-5645) Use async ZookeeperClient in SimpleAclAuthorizer

Ismael Juma created KAFKA-5645: -- Summary: Use async ZookeeperClient in SimpleAclAuthorizer Key: KAFKA-5645 URL: https://issues.apache.org/jira/browse/KAFKA-5645 Project: Kafka Issue Type:

Re: [VOTE] KIP-167 (Addendum): Add interface for the state store restoration process

+1 On Tue, 25 Jul 2017 at 18:17 Sriram Subramanian wrote: > +1 > > On Fri, Jul 21, 2017 at 12:08 PM, Guozhang Wang > wrote: > > > +1 > > > > On Thu, Jul 20, 2017 at 11:00 PM, Matthias J. Sax > > > wrote: > > > > > +1 > > > > > >

[jira] [Resolved] (KAFKA-5328) consider switching json parser from scala to jackson

[ https://issues.apache.org/jira/browse/KAFKA-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5328. Resolution: Duplicate Duplicate of KAFKA-1595. > consider switching json parser from scala to

[jira] [Resolved] (KAFKA-3210) Using asynchronous calls through the raw ZK API in ZkUtils

[ https://issues.apache.org/jira/browse/KAFKA-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3210. Resolution: Won't Fix We are following a slightly different approach, see KAFKA-5501. > Using

[GitHub] kafka pull request #3580: MINOR: Next release will be 1.0.0

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3580 MINOR: Next release will be 1.0.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka bump-to-1.0.0-SNAPSHOT Alternatively you can

[GitHub] kafka pull request #3579: Bump version to 0.11.0.1-SNAPSHOT

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3579 Bump version to 0.11.0.1-SNAPSHOT You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka bump-to-0.11.0.1-SNAPSHOT Alternatively you can

Re: [DISCUSS] KIP-179: Change ReassignPartitionsCommand to use AdminClient

I've updated the KIP to fix those niggles, but I've not factored out the topic name from the ReplicaStatusRequest, yet. Looking at the topic creation APIs in more detail, the CreateTopicsOptions has * `shouldValidateOnly()`, which would make a lot of sense for the alter topic APIs *

Jenkins build is back to normal : kafka-trunk-jdk7 #2573

See

[jira] [Created] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime

Manikumar created KAFKA-5644: Summary: Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime Key: KAFKA-5644 URL: https://issues.apache.org/jira/browse/KAFKA-5644 Project:

Re: [DISCUSS] KIP-179: Change ReassignPartitionsCommand to use AdminClient

Thanks Paolo, * in the "Public Interfaces" section you wrote > alterTopics(Set) but then a collection is used (instead of a > set) in the Proposed Changes section. I'm ok with collection. > Agree it should be Collection. > * in the summary of the alterTopics method you say "The request

[GitHub] kafka pull request #3578: KAFKA-5643: Using _DUCKTAPE_OPTIONS has no effect ...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3578 KAFKA-5643: Using _DUCKTAPE_OPTIONS has no effect on executing tests Added handling of _DUCKTAPE_OPTIONS (mainly for enabling debugging) You can merge this pull request into a Git repository by

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

Paolo Patierno created KAFKA-5643: - Summary: Using _DUCKTAPE_OPTIONS has no effect on executing tests Key: KAFKA-5643 URL: https://issues.apache.org/jira/browse/KAFKA-5643 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk8 #1850

See

[GitHub] kafka pull request #3516: KAFKA-5562: execute state dir cleanup on single th...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3516 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk7 #2572

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[GitHub] kafka pull request #3577: MINOR: Added some tips for running a single test f...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3577 MINOR: Added some tips for running a single test file, test class and/or test method Added some tips for running a single test file, test class and/or test method on the documentation landing

[GitHub] kafka pull request #3569: MINOR: enforce setting listeners in CREATE state.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3569 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk7 #2571

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

Build failed in Jenkins: kafka-trunk-jdk7 #2570

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[GitHub] kafka pull request #3576: Fix typo in SMT doc : s/RegexpRouter/RegexRouter

GitHub user rmoff opened a pull request: https://github.com/apache/kafka/pull/3576 Fix typo in SMT doc : s/RegexpRouter/RegexRouter You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmoff/kafka patch-1 Alternatively you can

Build failed in Jenkins: kafka-trunk-jdk8 #1849

See Changes: [junrao] KAFKA-4602; KIP-72 - Allow putting a bound on memory consumed by -- [...truncated 2.11 MB...]

[jira] [Resolved] (KAFKA-5501) introduce async ZookeeperClient

[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman resolved KAFKA-5501. - Resolution: Fixed > introduce async ZookeeperClient > --- > >

[jira] [Created] (KAFKA-5642) use async ZookeeperClient everywhere

Onur Karaman created KAFKA-5642: --- Summary: use async ZookeeperClient everywhere Key: KAFKA-5642 URL: https://issues.apache.org/jira/browse/KAFKA-5642 Project: Kafka Issue Type: Sub-task

Build failed in Jenkins: kafka-trunk-jdk7 #2569

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[jira] [Reopened] (KAFKA-5501) use async zookeeper apis everywhere

[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-5501: > use async zookeeper apis everywhere > --- > > Key:

Build failed in Jenkins: kafka-trunk-jdk7 #2568

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

Build failed in Jenkins: kafka-trunk-jdk7 #2567

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[jira] [Resolved] (KAFKA-5501) use async zookeeper apis everywhere

[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5501. Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3427

[GitHub] kafka pull request #3427: KAFKA-5501 [WIP]: use async zookeeper apis everywh...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3427 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk7 #2566

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on cassandra12 (cassandra ubuntu) in workspace

[GitHub] kafka pull request #2330: KAFKA-4602 - KIP-72 - Allow putting a bound on mem...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2330 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is