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 shall

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 to contribute to kafka. I a

Re: setting up kafka github

Hello, In this approach, I think setting it up according to the second method that I described in my earlier email should work. But, is this method what other contributors are also using ? Or are they using the first methods that I described? Thanks, Mojhaha On Sat, Nov 14, 2015 at 4:45 PM, jean

[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` > ---

[jira] [Commented] (KAFKA-2746) Add support for using ConsumerGroupCommand on secure install

[ https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15005389#comment-15005389 ] Ismael Juma commented on KAFKA-2746: [~singhashish], it would be nice to get this into

[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-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 > Implemen

[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: KAFKA

[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-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-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-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 top

[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 failur

[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-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 sa

[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-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] [Updated] (KAFKA-2479) Add CopycatExceptions to indicate transient and permanent errors in a connector/task

[ https://issues.apache.org/jira/browse/KAFKA-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2479: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add CopycatExceptions to indicate transient and

[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 p

[jira] [Updated] (KAFKA-2387) Improve KafkaConsumer API

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

[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 connect

[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 should

[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 the

[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-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 repl

[jira] [Updated] (KAFKA-2649) Add support for custom partitioner in sink nodes

[ https://issues.apache.org/jira/browse/KAFKA-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2649: --- Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add support for custom partitioner in sink node

[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-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 with

[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-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] [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, SAS

[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 repor

[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-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 a

[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 to

[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-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 >

[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 enabl

[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&focusedCommentId=15005498#comment-15005498 ] ASF GitHub Bot commented on KAFKA-2624: --- Github user asfgit closed the pull request

[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

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 ubun

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) in

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 > testP

[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` >

[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 actua

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 fra

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 fo

[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&focusedCommentId=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 Alternative

[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&focusedCommentId=15005727#comment-15005727 ] jin xing commented on KAFKA-2605: - https://issues.apache.org/jira/browse/KAFKA-2605?jql=pr

[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&focusedCommentId=15005727#comment-15005727 ] jin xing edited comment on KAFKA-2605 at 11/15/15 5:00 AM: --- yes,

[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, NotImplementedEr

[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&focusedCommentId=15005772#comment-15005772 ] ASF GitHub Bot commented on KAFKA-2605: --- GitHub user ZoneMayor opened a pull request