Re: setting up kafka github

Hello, I'm new to kafka too, but I think this page can help you : https://help.github.com/articles/using-pull-requests/ It describes exactly the process to follow. Regards. 2015-11-14 11:49 GMT+01:00 mojhaha kiklasds : > Hello, > > I'm new to github usage but I want

setting up kafka github

Hello, I'm new to github usage but I want to contribute to kafka. I am trying to setup my github repo based on the instructions mentioned here: https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes#ContributingCodeChanges-PullRequest I have one doubt though. Which repo

[jira] [Assigned] (KAFKA-2605) Replace `catch: Throwable` clauses with `NonFatal` or `NonControl`

[ https://issues.apache.org/jira/browse/KAFKA-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing reassigned KAFKA-2605: --- Assignee: jin xing > Replace `catch: Throwable` clauses with `NonFatal` or `NonControl` >

[GitHub] kafka pull request: KAFKA-2605: Replace 'catch: Throwable' clauses...

GitHub user ZoneMayor opened a pull request: https://github.com/apache/kafka/pull/531 KAFKA-2605: Replace 'catch: Throwable' clauses with 'NonFatal' 'catch: Throwable' will catch VirtualMachineError, ThreadDeath, InterruptedException, LinkageError, ControlThrowable,

[jira] [Commented] (KAFKA-2605) Replace `catch: Throwable` clauses with `NonFatal` or `NonControl`

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

[jira] [Commented] (KAFKA-2841) Group metadata cache loading is not safe when reloading a partition

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

[GitHub] kafka pull request: KAFKA-2841: safe group metadata cache loading/...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/530 KAFKA-2841: safe group metadata cache loading/unloading You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2841

[jira] [Comment Edited] (KAFKA-2605) Replace `catch: Throwable` clauses with `NonFatal` or `NonControl`

[ https://issues.apache.org/jira/browse/KAFKA-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15005727#comment-15005727 ] jin xing edited comment on KAFKA-2605 at 11/15/15 5:00 AM: --- yes, "case

[jira] [Commented] (KAFKA-2605) Replace `catch: Throwable` clauses with `NonFatal` or `NonControl`

[ https://issues.apache.org/jira/browse/KAFKA-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15005727#comment-15005727 ] jin xing commented on KAFKA-2605: -

[jira] [Updated] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2658: --- Fix Version/s: 0.9.1.0 > Implement SASL/PLAIN > > > Key: KAFKA-2658 >

[jira] [Updated] (KAFKA-2257) port replication_testsuite

[ https://issues.apache.org/jira/browse/KAFKA-2257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2257: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > port replication_testsuite >

[jira] [Updated] (KAFKA-2256) Port system tests

[ https://issues.apache.org/jira/browse/KAFKA-2256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2256: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Port system tests > -

[jira] [Updated] (KAFKA-2259) port offset_management_testsuite

[ https://issues.apache.org/jira/browse/KAFKA-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2259: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > port offset_management_testsuite >

[jira] [Updated] (KAFKA-2311) Consumer's ensureNotClosed method not thread safe

[ https://issues.apache.org/jira/browse/KAFKA-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2311: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Consumer's ensureNotClosed method not thread

[jira] [Updated] (KAFKA-2448) BrokerChangeListener missed broker id path ephemeral node deletion event.

[ https://issues.apache.org/jira/browse/KAFKA-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2448: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > BrokerChangeListener missed broker id

[jira] [Updated] (KAFKA-2378) Add Copycat embedded API

[ https://issues.apache.org/jira/browse/KAFKA-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2378: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add Copycat embedded API >

[jira] [Resolved] (KAFKA-2682) Authorization section in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2682. Resolution: Fixed This is done. > Authorization section in official docs >

[jira] [Updated] (KAFKA-2672) SendFailedException when new consumer is run with SSL

[ https://issues.apache.org/jira/browse/KAFKA-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2672: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 Description: When running new consumer

[jira] [Updated] (KAFKA-2643) Run mirror maker tests in ducktape with SSL

[ https://issues.apache.org/jira/browse/KAFKA-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2643: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Run mirror maker tests in ducktape with SSL >

[jira] [Updated] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2718: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Reuse of temporary directories leading

[jira] [Resolved] (KAFKA-2624) Truncate warn message logged after truncating partitions

[ https://issues.apache.org/jira/browse/KAFKA-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2624. Resolution: Fixed Fix Version/s: (was: 0.9.0.1) (was: 0.8.2.2)

[jira] [Commented] (KAFKA-2624) Truncate warn message logged after truncating partitions

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

[GitHub] kafka pull request: KAFKA-2624: Change log message position

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/287 --- 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_0.9.0_jdk7 #24

See Changes: [junrao] KAFKA-2624; Change log message position -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker Ubuntu ubuntu

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

See Changes: [junrao] KAFKA-2624; Change log message position -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker Ubuntu ubuntu)

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

See Changes: [junrao] KAFKA-2624; Change log message position -- [...truncated 1404 lines...] kafka.log.LogTest > testParseTopicPartitionNameForMissingPartition PASSED kafka.log.LogTest >

[jira] [Updated] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2658: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) 0.9.1.0 >

[jira] [Updated] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2658: --- Fix Version/s: (was: 0.9.1.0) > Implement SASL/PLAIN > > > Key:

[jira] [Updated] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2500: --- Fix Version/s: (was: 0.9.0.0) > Make logEndOffset available in the 0.8.3 Consumer >

[jira] [Updated] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2698: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > add paused API > -- > >

[jira] [Updated] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2000: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Delete consumer offsets from kafka once the

[jira] [Updated] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2103: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > kafka.producer.AsyncProducerTest

[jira] [Updated] (KAFKA-2365) Copycat checklist

[ https://issues.apache.org/jira/browse/KAFKA-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2365: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Copycat checklist > -

[jira] [Updated] (KAFKA-2376) Add Copycat metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2376: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Add Copycat metrics >

[jira] [Updated] (KAFKA-2370) Add pause/unpause connector support

[ https://issues.apache.org/jira/browse/KAFKA-2370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2370: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add pause/unpause connector support >

[jira] [Updated] (KAFKA-2642) Run replication tests in ducktape with SSL for clients

[ https://issues.apache.org/jira/browse/KAFKA-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2642: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Run

[jira] [Updated] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2667: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Copycat KafkaBasedLogTest.testSendAndReadToEnd

[jira] [Updated] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1326: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > New consumer checklist >

[jira] [Updated] (KAFKA-2688) Avoid forcing reload of `Configuration`

[ https://issues.apache.org/jira/browse/KAFKA-2688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2688: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Avoid forcing reload of `Configuration` >

[jira] [Updated] (KAFKA-2145) An option to add topic owners.

[ https://issues.apache.org/jira/browse/KAFKA-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2145: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > An option to add topic owners. >

[jira] [Updated] (KAFKA-2617) Move protocol field default values to Protocol

[ https://issues.apache.org/jira/browse/KAFKA-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2617: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Move protocol field default values to Protocol

[jira] [Updated] (KAFKA-2619) Kafka tools dont allow override of some properties using config files

[ https://issues.apache.org/jira/browse/KAFKA-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2619: --- Fix Version/s: (was: 0.9.0.0) > Kafka tools dont allow override of some properties using config files >

[jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors

[ https://issues.apache.org/jira/browse/KAFKA-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2483: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add support for batch/scheduled Copycat

[jira] [Updated] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2584: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > SecurityProtocol enum validation

[jira] [Updated] (KAFKA-2608) Recommend kafka_2.11 for 0.9.0.0 on the website

[ https://issues.apache.org/jira/browse/KAFKA-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2608: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Recommend kafka_2.11 for 0.9.0.0 on

[jira] [Updated] (KAFKA-2692) Add ducktape tests for SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2692: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add ducktape tests for SASL/Kerberos >

[jira] [Updated] (KAFKA-2732) Add support for consumer test with ZK Auth, SASL and SSL

[ https://issues.apache.org/jira/browse/KAFKA-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2732: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add support for consumer test with ZK Auth,

[jira] [Updated] (KAFKA-2789) Update upgrade system test to catch issue reported in KAFKA-2756

[ https://issues.apache.org/jira/browse/KAFKA-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2789: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Update upgrade system test to catch issue

[jira] [Updated] (KAFKA-2787) Refactor gradle build

[ https://issues.apache.org/jira/browse/KAFKA-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2787: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Refactor gradle build > -

[jira] [Updated] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-313: -- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Add JSON/CSV output and looping options

[jira] [Updated] (KAFKA-2146) adding partition did not find the correct startIndex

[ https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2146: --- Fix Version/s: (was: 0.9.0.0) > adding partition did not find the correct startIndex >

[jira] [Updated] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

[ https://issues.apache.org/jira/browse/KAFKA-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2422: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Allow copycat connector plugins to be

[jira] [Updated] (KAFKA-2542) Reuse Throttler code

[ https://issues.apache.org/jira/browse/KAFKA-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2542: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) > Reuse Throttler code >

Re: [VOTE] 0.9.0.0 Candiate 2

+1 (binding) 1. ran unit tests On Fri, Nov 13, 2015, at 06:28 PM, Jun Rao wrote: > This is the second candidate for release of Apache Kafka 0.9.0.0. This a > major release that includes (1) authentication (through SSL and SASL) and > authorization, (2) a new java consumer, (3) a Kafka connect

Re: [VOTE] 0.9.0.0 Candiate 2

+1 (binding) 1. ran unit tests 2. ran simple tests (producer, consumer) with sasl, ssl and non-secure. Thanks, Harsha On Sat, Nov 14, 2015, at 02:42 PM, Harsha wrote: > +1 (binding) > 1. ran unit tests > > On Fri, Nov 13, 2015, at 06:28 PM, Jun Rao wrote: > > This is the second candidate

[jira] [Resolved] (KAFKA-2688) Avoid forcing reload of `Configuration`

[ https://issues.apache.org/jira/browse/KAFKA-2688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2688. Resolution: Fixed Fix Version/s: (was: 0.9.1.0) 0.9.0.0 This was

[jira] [Assigned] (KAFKA-2688) Avoid forcing reload of `Configuration`

[ https://issues.apache.org/jira/browse/KAFKA-2688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2688: -- Assignee: Ismael Juma (was: Flavio Junqueira) > Avoid forcing reload of `Configuration` >