[GitHub] kafka pull request: fix:lru accessOrder=true

GitHub user dingjun84 opened a pull request: https://github.com/apache/kafka/pull/1104 fix:lru accessOrder=true fix:lru accessOrder=true You can merge this pull request into a Git repository by running: $ git pull https://github.com/dingjun84/kafka 0.8.2 Alternatively you ca

[jira] [Created] (KAFKA-3432) Cluster.update() thread-safety

Ismael Juma created KAFKA-3432: -- Summary: Cluster.update() thread-safety Key: KAFKA-3432 URL: https://issues.apache.org/jira/browse/KAFKA-3432 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203901#comment-15203901 ] Mikael Sundberg commented on KAFKA-3172: Im seeing the same thing. A machine can s

[jira] [Commented] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203906#comment-15203906 ] Ismael Juma commented on KAFKA-3172: Please make sure you are using 0.9.0.1 as it incl

[jira] [Commented] (KAFKA-3428) Remove metadata sync bottleneck from mirrormaker's producer

[ https://issues.apache.org/jira/browse/KAFKA-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203919#comment-15203919 ] Ismael Juma commented on KAFKA-3428: Say someone wrote code like: {code} synchronized

[GitHub] kafka pull request: KAFKA-3431: Remove `o.a.k.common.BrokerEndPoin...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1105 KAFKA-3431: Remove `o.a.k.common.BrokerEndPoint` in favour of `Node` Also included a minor efficiency improvement in kafka.cluster.EndPoint. You can merge this pull request into a Git repository by ru

[jira] [Commented] (KAFKA-3431) Move `BrokerEndPoint` from `o.a.k.common` to `o.a.k.common.internals`

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

[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 ] Ismael Juma updated KAFKA-2672: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > SendFailedException when new consumer

[jira] [Updated] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2939: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Make AbstractConfig.logUnused() tunab

[jira] [Updated] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2939: --- Issue Type: Improvement (was: Bug) > Make AbstractConfig.logUnused() tunable for clients > --

[jira] [Updated] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2939: --- Labels: newbie (was: ) > Make AbstractConfig.logUnused() tunable for clients > --

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203958#comment-15203958 ] Ismael Juma commented on KAFKA-2939: The current code works as expected, but it could

[jira] [Updated] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

[ https://issues.apache.org/jira/browse/KAFKA-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2901: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Extend ListGroups and DescribeGroup A

[jira] [Commented] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203968#comment-15203968 ] Ismael Juma commented on KAFKA-3203: Is this something that are still trying to do for

[jira] [Updated] (KAFKA-3163) KIP-33 - Add a time based log index to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3163: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > KIP-33 - Add a time based log index t

[jira] [Updated] (KAFKA-3128) Add metrics for ZooKeeper events

[ https://issues.apache.org/jira/browse/KAFKA-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3128: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Add metrics for ZooKeeper events > --

[jira] [Commented] (KAFKA-3163) KIP-33 - Add a time based log index to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203970#comment-15203970 ] Ismael Juma commented on KAFKA-3163: We agreed in the KIP call to move this to 0.10.1.

[jira] [Commented] (KAFKA-3285) Mirror Maker whitelist behavior differs between old and new consumer

[ https://issues.apache.org/jira/browse/KAFKA-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203983#comment-15203983 ] Ismael Juma commented on KAFKA-3285: [~granthenke], can we close this now that KAFKA-2

[jira] [Commented] (KAFKA-2511) KIP-31 & KIP-32: message format change + adding timestamp to messages

[ https://issues.apache.org/jira/browse/KAFKA-2511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203985#comment-15203985 ] Ismael Juma commented on KAFKA-2511: All sub-tasks are done, so we can close this too.

[jira] [Resolved] (KAFKA-2511) KIP-31 & KIP-32: message format change + adding timestamp to messages

[ https://issues.apache.org/jira/browse/KAFKA-2511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2511. Resolution: Fixed > KIP-31 & KIP-32: message format change + adding timestamp to messages >

[jira] [Updated] (KAFKA-3302) Pass kerberos keytab and principal as part of client config

[ https://issues.apache.org/jira/browse/KAFKA-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3302: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Pass kerberos keytab and principal as

[jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method

[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3248: --- Reviewer: Gwen Shapira > AdminClient Blocks Forever in send Method > -

[jira] [Updated] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3177: --- Reviewer: Jason Gustafson > Kafka consumer can hang when position() is called on a non-existing partit

[jira] [Updated] (KAFKA-2720) Periodic purging groups in the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2720: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Periodic purging groups in the coordi

[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 ] Ismael Juma updated KAFKA-2789: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Update upgrade system test to catch i

[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 ] Ismael Juma updated KAFKA-2145: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > An option to add topic owners. > ---

[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 ] Ismael Juma updated KAFKA-2692: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Add ducktape tests for SASL/Kerberos

[jira] [Updated] (KAFKA-2952) Add ducktape test for secure->unsecure ZK migration

[ https://issues.apache.org/jira/browse/KAFKA-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2952: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Add ducktape test for secure->unsecur

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

[ https://issues.apache.org/jira/browse/KAFKA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2387: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Improve KafkaConsumer 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 ] Ismael Juma updated KAFKA-1326: --- Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > New consumer checklist >

[jira] [Resolved] (KAFKA-3285) Mirror Maker whitelist behavior differs between old and new consumer

[ https://issues.apache.org/jira/browse/KAFKA-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-3285. Resolution: Fixed Assignee: Grant Henke Marking as resolved. The new consumer will now ignore

[jira] [Updated] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3203: --- Fix Version/s: (was: 0.10.0.0) > Add UnknownCodecException and UnknownMagicByteException to error

request for edit access to Kafka wiki

Hi All, I want to publish C++ Kafka client. I have my git repository ready. Now I want add entry on Kafka “Clients” page (Confluence wiki page) for this new client. I did create my login for the Confluence and login with that. But I am not able to edit the page. Do I require to do some other st

[jira] [Created] (KAFKA-3433) Document stability annotations

Grant Henke created KAFKA-3433: -- Summary: Document stability annotations Key: KAFKA-3433 URL: https://issues.apache.org/jira/browse/KAFKA-3433 Project: Kafka Issue Type: Improvement Affects

[jira] [Updated] (KAFKA-3409) Mirror maker hangs indefinitely due to commit

[ https://issues.apache.org/jira/browse/KAFKA-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3409: --- Fix Version/s: 0.10.0.0 > Mirror maker hangs indefinitely due to commit > ---

[jira] [Updated] (KAFKA-3409) Mirror maker hangs indefinitely due to commit

[ https://issues.apache.org/jira/browse/KAFKA-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3409: --- Priority: Critical (was: Major) > Mirror maker hangs indefinitely due to commit > --

[jira] [Commented] (KAFKA-3409) Mirror maker hangs indefinitely due to commit

[ https://issues.apache.org/jira/browse/KAFKA-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204370#comment-15204370 ] Ismael Juma commented on KAFKA-3409: I am bumping the priority and setting the fix ver

[jira] [Commented] (KAFKA-1313) Support adding replicas to existing topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204488#comment-15204488 ] Bingkun Guo commented on KAFKA-1313: +1 on supporting "replication-factor" option in "

[jira] [Commented] (KAFKA-3400) Topic stop working / can't describe topic

[ https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204540#comment-15204540 ] Tobias commented on KAFKA-3400: --- I think the issue I've hit is http://search-hadoop.com/m/uy

[jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1342: Assignee: Joel Koshy (was: Jiangjie Qin) > Slow controlled shutdowns can result in stale shutdown r

New release branch 0.10.0

Hello Kafka developers and friends, As promised, we now have a release branch for 0.10.0 release (with 0.10.0.0 as the version). Trunk has been bumped to 0.10.1.0-SNAPSHOT. I'll be going over the JIRAs to move every non-blocker from this release to the next release. >From this point, most change

[jira] [Created] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

Jason Gustafson created KAFKA-3434: -- Summary: Add old ConsumerRecord constructor for compatibility Key: KAFKA-3434 URL: https://issues.apache.org/jira/browse/KAFKA-3434 Project: Kafka Issue

[jira] [Updated] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

[ https://issues.apache.org/jira/browse/KAFKA-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3434: --- Fix Version/s: 0.10.0.0 > Add old ConsumerRecord constructor for compatibility > -

[jira] [Commented] (KAFKA-2670) add sampling rate to MirrorMaker

[ https://issues.apache.org/jira/browse/KAFKA-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204620#comment-15204620 ] Dustin Cote commented on KAFKA-2670: I agree with Joel, it's probably better to keep t

[GitHub] kafka pull request: MINOR: add back old constructor of ConsumerRec...

Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/1027 --- 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 e

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

See Changes: [cshapi] Changing version to 0.10.1.0-SNAPSHOT -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu yahoo-not-

[jira] [Created] (KAFKA-3435) Remove `Unstable` annotation from new Java Consumer

Ismael Juma created KAFKA-3435: -- Summary: Remove `Unstable` annotation from new Java Consumer Key: KAFKA-3435 URL: https://issues.apache.org/jira/browse/KAFKA-3435 Project: Kafka Issue Type: Tas

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

See Changes: [cshapi] Changing version to 0.10.1.0-SNAPSHOT -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu yahoo-not

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3436: Description: Currently rolling bounce a Kafka cluster with tens of thousands of partitions can take

[jira] [Created] (KAFKA-3436) Speed up controlled shutdown.

Jiangjie Qin created KAFKA-3436: --- Summary: Speed up controlled shutdown. Key: KAFKA-3436 URL: https://issues.apache.org/jira/browse/KAFKA-3436 Project: Kafka Issue Type: Improvement Affects

[jira] [Updated] (KAFKA-3319) Improve session timeout broker and client configuration documentation

[ https://issues.apache.org/jira/browse/KAFKA-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3319: --- Summary: Improve session timeout broker and client configuration documentation (was: Improve

[jira] [Updated] (KAFKA-3319) Improve session timeout broker and client configuration documentation

[ https://issues.apache.org/jira/browse/KAFKA-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3319: --- Description: The current descriptions of the consumer's session timeout and the broker's group

[GitHub] kafka pull request: KAFKA-3319: improve session timeout broker/cli...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1106 KAFKA-3319: improve session timeout broker/client config documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3

[jira] [Commented] (KAFKA-3319) Improve session timeout broker and client configuration documentation

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

[jira] [Created] (KAFKA-3437) We don't need sitedocs package for every scala version

Gwen Shapira created KAFKA-3437: --- Summary: We don't need sitedocs package for every scala version Key: KAFKA-3437 URL: https://issues.apache.org/jira/browse/KAFKA-3437 Project: Kafka Issue Type

[jira] [Work started] (KAFKA-3412) Multiple commitAsync() calls causes SendFailedException in commit callback

[ https://issues.apache.org/jira/browse/KAFKA-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3412 started by Jason Gustafson. -- > Multiple commitAsync() calls causes SendFailedException in commit callback

[jira] [Created] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

Ben Stopford created KAFKA-3438: --- Summary: Rack Aware Replica Reassignment should warn of overloaded brokers Key: KAFKA-3438 URL: https://issues.apache.org/jira/browse/KAFKA-3438 Project: Kafka

[jira] [Updated] (KAFKA-3388) Producer should only timeout a batch in the accumulator when metadata is missing.

[ https://issues.apache.org/jira/browse/KAFKA-3388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3388: Priority: Critical (was: Blocker) > Producer should only timeout a batch in the accumulator when me

[jira] [Commented] (KAFKA-3437) We don't need sitedocs package for every scala version

[ https://issues.apache.org/jira/browse/KAFKA-3437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204906#comment-15204906 ] Gwen Shapira commented on KAFKA-3437: - also, it looks like "releaseTarGzAll" generates

[jira] [Created] (KAFKA-3439) Document possible exception thrown in public APIs

Guozhang Wang created KAFKA-3439: Summary: Document possible exception thrown in public APIs Key: KAFKA-3439 URL: https://issues.apache.org/jira/browse/KAFKA-3439 Project: Kafka Issue Type: S

[jira] [Created] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

Guozhang Wang created KAFKA-3440: Summary: Add Javadoc for KTable (changelog stream) and KStream (record stream) Key: KAFKA-3440 URL: https://issues.apache.org/jira/browse/KAFKA-3440 Project: Kafka

[GitHub] kafka pull request: MINOR: Add InterfaceStability.Unstable annotat...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1097 --- 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 enab

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

See Changes: [wangguoz] MINOR: Add InterfaceStability.Unstable annotations to some Kafka Streams -- [...truncated 1610 lines...] jdk1.8.0_45/lib/visualvm/platform/modules/locale/org-openide-io_j

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

See Changes: [wangguoz] MINOR: Add InterfaceStability.Unstable annotations to some Kafka Streams -- [...truncated 1711 lines...] jdk1.7.0_51/jre/lib/zi/Asia/Yakutsk jdk1.7.0_51/jre/lib/zi/Asia/

[jira] [Created] (KAFKA-3441) 0.10.0 documentation still says "0.9.0"

Gwen Shapira created KAFKA-3441: --- Summary: 0.10.0 documentation still says "0.9.0" Key: KAFKA-3441 URL: https://issues.apache.org/jira/browse/KAFKA-3441 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3441) 0.10.0 documentation still says "0.9.0"

[ https://issues.apache.org/jira/browse/KAFKA-3441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3441: Description: See here: https://github.com/apache/kafka/blob/trunk/docs/documentation.html And here

[GitHub] kafka pull request: MINOR: fix documentation version

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/1107 MINOR: fix documentation version This will need to be double-committed. You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka fix-doc-v

[GitHub] kafka pull request: MINOR: fix documentation version

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1107 --- 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 enab

[GitHub] kafka pull request: KAFKA-3412: multiple asynchronous commits caus...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1108 KAFKA-3412: multiple asynchronous commits causes send failures You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3412 Alt

[jira] [Commented] (KAFKA-3412) Multiple commitAsync() calls causes SendFailedException in commit callback

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

[jira] [Updated] (KAFKA-3283) Consider marking the new consumer as production-ready

[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3283: --- Description: Ideally, we would: * Remove the beta label * Filling any critical gaps in functionality

[GitHub] kafka pull request: MINOR: update new version in additional places

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/1109 MINOR: update new version in additional places Note: This goes only to trunk. 0.10.0 branch will need a separate PR with different versions. You can merge this pull request into a Git repository b

[GitHub] kafka pull request: MINOR: update new version in additional places

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1109 --- 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 enab

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205083#comment-15205083 ] Ewen Cheslack-Postava commented on KAFKA-1173: -- [~gwenshap] Maybe? I had been

[GitHub] kafka pull request: MINOR: update new version in additional places

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/1110 MINOR: update new version in additional places matching set of version fixes. @ewencp @junrao You can merge this pull request into a Git repository by running: $ git pull https://github.com/g

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

See Changes: [me] MINOR: fix documentation version [me] MINOR: update new version in additional places -- Started by an SCM change [EnvInject] - Loading node environment variables. Building rem

[VOTE] 0.10.0.0 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 0.10.0.0. This is a major release that includes: (1) New message format including timestamps (2) client interceptor API (3) Kafka Streams. Since this is a major release, we will give people

[jira] [Commented] (KAFKA-3441) 0.10.0 documentation still says "0.9.0"

[ https://issues.apache.org/jira/browse/KAFKA-3441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205119#comment-15205119 ] Gwen Shapira commented on KAFKA-3441: - The most obvious part was fixed here: https://g

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

See Changes: [me] MINOR: fix documentation version [me] MINOR: update new version in additional places -- [...truncated 1610 lines...] jdk1.8.0_45/lib/visualvm/platform/modules/locale/org-openid

Re: kafka-streams: Using custom partitioner with higher level DSL constructs?

Hello Ben, 1. Currently Kafka Streams high-level DSL does not take the StreamPartitioner yet, please feel free to file a JIRA so that we can keep track and discuss of whether / how to incorporate it into Kafka Streams DSL. 2. As for now, you can do two work arounds: 1) use `process()` function t

Re: kafka-streams: Using custom partitioner with higher level DSL constructs?

Also, have you looked at Kafka Connect released in 0.9? It has a MySQL binlog connector implementation in progress, just thinking maybe you would be interested to check it out and see if there are any feedbacks that you want to give. https://github.com/wushujames/kafka-mysql-connector Guozhang O

Re: KStreams Partition Assignment

Hi Mike, Kafka Streams is suitable for distributed environment. You can read this section of the web docs for more details: http://docs.confluent.io/2.1.0-alpha1/streams/architecture.html#parallelism-model As for the Kafka Streams' customized partition assignor under the Kafka group management p

[jira] [Created] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

Dana Powers created KAFKA-3442: -- Summary: FetchResponse size exceeds max.partition.fetch.bytes Key: KAFKA-3442 URL: https://issues.apache.org/jira/browse/KAFKA-3442 Project: Kafka Issue Type: Bu

Re: [VOTE] 0.10.0.0 RC0

I filed a bug re max.partition.fetch.bytes here: https://issues.apache.org/jira/browse/KAFKA-3442 Would it be useful to create a 0.10.0.0-rc0 version for JIRA tickets? Or should issues just get filed against 0.10.0.0 ? -Dana On Mon, Mar 21, 2016 at 1:53 PM, Gwen Shapira wrote: > Hello Kafka u

[jira] [Updated] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3442: --- Fix Version/s: 0.10.0.0 > FetchResponse size exceeds max.partition.fetch.bytes > -

[jira] [Commented] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205387#comment-15205387 ] Ismael Juma commented on KAFKA-3442: [~junrao], do you think this is a result of KIP-3

Re: [VOTE] 0.10.0.0 RC0

Thank you! The affected version should be 0.10.0.0 fixVersion will be 0.10.0.0 if you think its a show-stopper for the release (in this case, make it a blocker too). If its not a blocker, fixVersion can be either left empty or set to 0.10.1.0 Gwen On Mon, Mar 21, 2016 at 4:47 PM, Dana Powers wr

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

See -- Started by user gwenshap [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu ubuntu ubuntu-us golang-ppa) in workspace

[jira] [Commented] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205396#comment-15205396 ] Jun Rao commented on KAFKA-3442: [~dana.powers], could you share you test? Thanks, > Fetc

[jira] [Updated] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dana Powers updated KAFKA-3442: --- Priority: Blocker (was: Major) > FetchResponse size exceeds max.partition.fetch.bytes > -

Re: Build failed in Jenkins: kafka-trunk-jdk7 #1134

In case you were wondering, these failures were due to the fact that the Gradle build configs in Apache Jenkins got messed up somehow: https://issues.apache.org/jira/browse/INFRA-11514 Andrew Bayer has fixed the issue. Ismael On Mon, Mar 21, 2016 at 8:45 PM, Apache Jenkins Server < jenk...@buil

[jira] [Updated] (KAFKA-3432) Cluster.update() thread-safety

[ https://issues.apache.org/jira/browse/KAFKA-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3432: --- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > Cluster.update() thread-safety >

[jira] [Assigned] (KAFKA-3432) Cluster.update() thread-safety

[ https://issues.apache.org/jira/browse/KAFKA-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3432: -- Assignee: Ismael Juma > Cluster.update() thread-safety > -- > >

[jira] [Commented] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205411#comment-15205411 ] Dana Powers commented on KAFKA-3442: # clone kafka-python repo git clone https://githu

[jira] [Comment Edited] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205411#comment-15205411 ] Dana Powers edited comment on KAFKA-3442 at 3/22/16 12:13 AM: --

[jira] [Updated] (KAFKA-3431) Move `BrokerEndPoint` from `o.a.k.common` to `o.a.k.common.internals`

[ https://issues.apache.org/jira/browse/KAFKA-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3431: --- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > Move `BrokerEndPoint` from `o.a.k.com

[jira] [Updated] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

[ https://issues.apache.org/jira/browse/KAFKA-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3434: --- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > Add old ConsumerRecord constructor fo

[jira] [Updated] (KAFKA-3419) New consumer javadoc unclear on topic subscription vs partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-3419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3419: --- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > New consumer javadoc unclear on topic

[jira] [Updated] (KAFKA-3418) Add section on detecting consumer failures in new consumer javadoc

[ https://issues.apache.org/jira/browse/KAFKA-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3418: --- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > Add section on detecting consumer fai

[jira] [Created] (KAFKA-3443) Support regex topics in addSource() and stream()

Guozhang Wang created KAFKA-3443: Summary: Support regex topics in addSource() and stream() Key: KAFKA-3443 URL: https://issues.apache.org/jira/browse/KAFKA-3443 Project: Kafka Issue Type: Su

  1   2   >