[GitHub] kafka pull request #3824: MINOR: Fix help in consumer group tool

GitHub user ueokande opened a pull request: https://github.com/apache/kafka/pull/3824 MINOR: Fix help in consumer group tool help in kafka-consumer-groups.sh change You can merge this pull request into a Git repository by running: $ git pull https://github.com/ueokande/kafka

Re: [DISCUSS] KIP-199: Add Kafka Connect offset reset tool

bq. How about calling it kafka-connect-source-offset-tool.sh This is better. Going over existing .sh files, some have verb in their names while some don't. +1 from me. On Sun, Sep 10, 2017 at 2:53 PM, Randall Hauch wrote: > Thanks for the comments! Specific comments inline

[jira] [Created] (KAFKA-5867) Kafka Connect applications should log info message when starting up

Randall Hauch created KAFKA-5867: Summary: Kafka Connect applications should log info message when starting up Key: KAFKA-5867 URL: https://issues.apache.org/jira/browse/KAFKA-5867 Project: Kafka

Re: [DISCUSS] KIP-199: Add Kafka Connect offset reset tool

Thanks for the comments! Specific comments inline below. Regards, Randall On Sun, Sep 10, 2017 at 2:42 PM, Ted Yu wrote: > bq. connector restart and the next message > > The last part of the sentence seems to be incomplete. > Fixed. > bq. command line tool called

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

See Changes: [rajinisivaram] MINOR: Fix transient failure in -- [...truncated 2.52 MB...] org.apache.kafka.streams.integration.RegexSourceIntegrationTest >

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

See

Re: [DISCUSS] KIP-199: Add Kafka Connect offset reset tool

bq. connector restart and the next message The last part of the sentence seems to be incomplete. bq. command line tool called kafka-connect-source-offset-reset.sh >From the description, the tool does more than resetting (e.g. deleting). How about calling it kafka-connect-source-offset-tool.sh

[GitHub] kafka pull request #3823: MINOR: Fix transient failure in SelectorTest.testC...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3823 ---

[DISCUSS] KIP-199: Add Kafka Connect offset reset tool

Hi all, KIP-199 [1] describes a new tool that will allow Connect operators to read, update, and remove offsets stored by Connect runtime. This capability has been often asked for by Connect users. The proposal is simple but flexible. Please review and add feedback. Best regards, Randall [1]

[GitHub] kafka pull request #3823: MINOR: Fix transient failure in SelectorTest.testC...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3823 MINOR: Fix transient failure in SelectorTest.testCloseConnectionInClosingState `SelectorTest.testCloseConnectionInClosingState` creates a channel with some staging receives and moves time

[GitHub] kafka pull request #3803: KAFKA-5845; KafkaController should send LeaderAndI...

GitHub user lindong28 reopened a pull request: https://github.com/apache/kafka/pull/3803 KAFKA-5845; KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown You can merge this pull request into a Git repository by running: $ git pull

Re: [VOTE] KIP-188 - Add new metrics to support health checks

This vote has passed with 4 binding votes (Ismael, Jason, Jun, me) and 3 non-binding votes (Manikumar, Thomas Crayford, Mickael). Many thanks for the votes and feedback. I will update the KIP page. Regards, Rajini On Fri, Sep 8, 2017 at 5:12 PM, Rajini Sivaram wrote:

[jira] [Created] (KAFKA-5866) Let source/sink task to finish their job before exit

Oleg Kuznetsov created KAFKA-5866: - Summary: Let source/sink task to finish their job before exit Key: KAFKA-5866 URL: https://issues.apache.org/jira/browse/KAFKA-5866 Project: Kafka Issue

Re: [DISCUSS] KIP-196: Add metrics to Kafka Connect framework

Thanks, Gwen. That's a great idea, so I've changed the KIP to add those metrics. I've also made a few other changes: 1. The context of all metrics is limited to the activity within the worker. This wasn't clear before, so I changed the motivation and metric descriptions to explicitly