[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

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

[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

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

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

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

[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

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

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

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

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

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

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

[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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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: --- Affects Version/s: 0.9.0.0 Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Implemen

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

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

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

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