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

See

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

See Changes: [cshapi] KAFKA-2803: Add hard bounce system test for Kafka Connect. [cshapi] MINOR: Introduce `installAll` and accept major as well as full Scala -- [...truncated 4432 lines...] org

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15026076#comment-15026076 ] Jason Gustafson commented on KAFKA-2887: There is probably wide agreement that aut

Build failed in Jenkins: kafka_0.9.0_jdk7 #42

See Changes: [cshapi] KAFKA-2881: Improve Consumer Configs and API Documentation -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker

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

See Changes: [wangguoz] KAFKA-2877: handle request timeout in sync group [cshapi] KAFKA-2881: Improve Consumer Configs and API Documentation -- [...truncated 1690 lines...] kafka.log.BrokerComp

[GitHub] kafka pull request: MINOR: Introduce `installAll` and accept major...

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

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

See Changes: [wangguoz] KAFKA-2877: handle request timeout in sync group [cshapi] KAFKA-2881: Improve Consumer Configs and API Documentation -- [...truncated 1752 lines...] kafka.log.BrokerComp

[jira] [Commented] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

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

Build failed in Jenkins: kafka_0.9.0_jdk7 #41

See Changes: [wangguoz] KAFKA-2877: handle request timeout in sync group -- [...truncated 5184 lines...] kafka.log.LogTest > testParseTopicPartitionNameForMissingTopic PASSED kafka.log.LogTest >

[jira] [Updated] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2803: Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was: Patch Available)

[GitHub] kafka pull request: KAFKA-2803: Add hard bounce system test for Ka...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/494 --- 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-2889) Problem running Kafka using -daemon switch

[ https://issues.apache.org/jira/browse/KAFKA-2889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Ing resolved KAFKA-2889. -- Resolution: Fixed Fix Version/s: (was: 0.9.0.0) I should not have reported this issue. Your

Re: group protocol/metadata documentation

Hey Dana, Have a look at this wiki, which has more detail on the consumer's embedded protocol: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Client-side+Assignment+Proposal . At the moment, the group protocol supports consumer groups and kafka connect groups. Kafka tooling currently dep

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025879#comment-15025879 ] Gwen Shapira commented on KAFKA-2881: - never mind, it was in trunk. I missed that comm

[jira] [Created] (KAFKA-2889) Problem running Kafka using -daemon switch

David Ing created KAFKA-2889: Summary: Problem running Kafka using -daemon switch Key: KAFKA-2889 URL: https://issues.apache.org/jira/browse/KAFKA-2889 Project: Kafka Issue Type: Bug Co

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025859#comment-15025859 ] Sriharsha Chintalapani commented on KAFKA-2887: --- [~nickpan47] already have a

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025854#comment-15025854 ] Yi Pan (Data Infrastructure) commented on KAFKA-2887: - HI, [~harsha_ch

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025845#comment-15025845 ] Gwen Shapira commented on KAFKA-2881: - Committed, but then noticed that Jun's fix for

[jira] [Comment Edited] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025843#comment-15025843 ] Sriharsha Chintalapani edited comment on KAFKA-2887 at 11/25/15 12:41 AM: --

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025843#comment-15025843 ] Sriharsha Chintalapani commented on KAFKA-2887: --- [~yipan] [~AWinterman] This

[jira] [Resolved] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2881. - Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.0 Issue resolved by pull

[jira] [Commented] (KAFKA-2881) Documentation improvement

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

[GitHub] kafka pull request: KAFKA-2881: Improve Consumer Configs and APIs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/584 --- 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] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025819#comment-15025819 ] Andrew Winterman commented on KAFKA-2887: - I'd be plus one on that. The alternativ

[jira] [Commented] (KAFKA-2804) Create / Update changelog topics upon state store initialization

[ https://issues.apache.org/jira/browse/KAFKA-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025817#comment-15025817 ] Gwen Shapira commented on KAFKA-2804: - Delete topic is supported since 0.8.2.X > Crea

[jira] [Commented] (KAFKA-2804) Create / Update changelog topics upon state store initialization

[ https://issues.apache.org/jira/browse/KAFKA-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025815#comment-15025815 ] Yi Pan (Data Infrastructure) commented on KAFKA-2804: - [~guozhang], as

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025804#comment-15025804 ] Yi Pan (Data Infrastructure) commented on KAFKA-2887: - Agree with [~AW

[jira] [Commented] (KAFKA-2877) Messages sometimes not delivered by new consumer after Kafka restart

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

[jira] [Resolved] (KAFKA-2877) Messages sometimes not delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2877. -- Resolution: Fixed Fix Version/s: 0.9.0.1 Issue resolved by pull request 582 [https://gith

[GitHub] kafka pull request: KAFKA-2877: handle request timeout in sync gro...

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

group protocol/metadata documentation

Hi all - I've been reading through the wiki docs and mailing list threads for the new JoinGroup/SyncGroup/Heartbeat APIs, hoping to add functionality to the python driver. It appears that there is a shared notion of group "protocols" (client publishes supported protocols, coordinator picks protocol

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025741#comment-15025741 ] ASF GitHub Bot commented on KAFKA-2881: --- Github user guozhangwang closed the pull re

[GitHub] kafka pull request: K2881: Improve Consumer Configs and APIs

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/584 K2881: Improve Consumer Configs and APIs You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2881 Alternatively you can rev

[GitHub] kafka-site pull request: KAFKA-2881: Organized Consumer APIs and C...

Github user guozhangwang closed the pull request at: https://github.com/apache/kafka-site/pull/5 --- 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

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025735#comment-15025735 ] ASF GitHub Bot commented on KAFKA-2881: --- Github user guozhangwang commented on the p

[GitHub] kafka-site pull request: KAFKA-2881: Organized Consumer APIs and C...

Github user guozhangwang commented on the pull request: https://github.com/apache/kafka-site/pull/5#issuecomment-159441903 Good point, will do that. --- 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

[jira] [Commented] (KAFKA-2888) Allow ConsoleConsumer to print a status update on some interval

[ https://issues.apache.org/jira/browse/KAFKA-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025615#comment-15025615 ] Nick Dimiduk commented on KAFKA-2888: - Perhaps this should be called "reporting-interv

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025610#comment-15025610 ] ASF GitHub Bot commented on KAFKA-2881: --- Github user gwenshap commented on the pull

[GitHub] kafka-site pull request: KAFKA-2881: Organized Consumer APIs and C...

Github user gwenshap commented on the pull request: https://github.com/apache/kafka-site/pull/5#issuecomment-159430950 The patch looks good, but I'm concerned that by committing to kafka-site directly, we will lose sync with the docs in the trunk. Mind making this a kafka trun

[jira] [Updated] (KAFKA-2888) Allow ConsoleConsumer to print a status update on some interval

[ https://issues.apache.org/jira/browse/KAFKA-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Dimiduk updated KAFKA-2888: Status: Patch Available (was: Open) > Allow ConsoleConsumer to print a status update on some interv

[jira] [Updated] (KAFKA-2888) Allow ConsoleConsumer to print a status update on some interval

[ https://issues.apache.org/jira/browse/KAFKA-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Dimiduk updated KAFKA-2888: Attachment: 2888.patch Suggested solution. > Allow ConsoleConsumer to print a status update on some

[jira] [Created] (KAFKA-2888) Allow ConsoleConsumer to print a status update on some interval

Nick Dimiduk created KAFKA-2888: --- Summary: Allow ConsoleConsumer to print a status update on some interval Key: KAFKA-2888 URL: https://issues.apache.org/jira/browse/KAFKA-2888 Project: Kafka

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025554#comment-15025554 ] ASF GitHub Bot commented on KAFKA-2881: --- Github user guozhangwang commented on the p

[GitHub] kafka-site pull request: KAFKA-2881: Organized Consumer APIs and C...

Github user guozhangwang commented on the pull request: https://github.com/apache/kafka-site/pull/5#issuecomment-159424104 Ping @gwenshap @junrao for reviews. --- 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 proje

[jira] [Commented] (KAFKA-2881) Documentation improvement

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

[GitHub] kafka-site pull request: KAFKA-2881: Organized Consumer APIs and C...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka-site/pull/5 KAFKA-2881: Organized Consumer APIs and Configs You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka-site K2881 Alternativ

[jira] [Comment Edited] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025546#comment-15025546 ] Andrew Winterman edited comment on KAFKA-2887 at 11/24/15 10:14 PM:

[jira] [Reopened] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Winterman reopened KAFKA-2887: - Reopening because the auto.create.topics.enable also controls whether or not a topic is creat

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025523#comment-15025523 ] Andrew Winterman commented on KAFKA-2887: - ah, I see that is is. Thanks! > TopicM

[jira] [Resolved] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Winterman resolved KAFKA-2887. - Resolution: Not A Problem > TopicMetadataRequest creates topic if it does not exist >

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025517#comment-15025517 ] Jason Gustafson commented on KAFKA-2887: [~AWinterman] Agreed. I added a note on t

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025494#comment-15025494 ] Andrew Winterman commented on KAFKA-2887: - In that case, shouldn't it be mentioned

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025446#comment-15025446 ] Jason Gustafson commented on KAFKA-2887: This is actually intentional. You can dis

[jira] [Commented] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025402#comment-15025402 ] Nick Dimiduk commented on KAFKA-1980: - I ran into this as well. Seems use of {{KafkaSt

[jira] [Commented] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025371#comment-15025371 ] Guozhang Wang commented on KAFKA-2881: -- @Jun has already fixed 1) above, this patch o

[jira] [Assigned] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2881: Assignee: Guozhang Wang > Documentation improvement > - > >

[jira] [Updated] (KAFKA-2881) Documentation improvement

[ https://issues.apache.org/jira/browse/KAFKA-2881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2881: - Affects Version/s: 0.9.0.0 > Documentation improvement > - > >

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15025355#comment-15025355 ] ASF GitHub Bot commented on KAFKA-2718: --- GitHub user rajinisivaram opened a pull req

[GitHub] kafka pull request: KAFKA-2718: Prevent temp directory being reuse...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/583 KAFKA-2718: Prevent temp directory being reused in parallel test runs Use Files.createTempDirectory to avoid reuse, for log directories create a new temp directory as parent You can merge this

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

See

[jira] [Commented] (KAFKA-2877) Messages sometimes not delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025225#comment-15025225 ] Jason Gustafson commented on KAFKA-2877: It looks like when we updated the new con

[jira] [Commented] (KAFKA-2877) Messages sometimes not delivered by new consumer after Kafka restart

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

[GitHub] kafka pull request: KAFKA-2877: handle request timeout in sync gro...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/582 KAFKA-2877: handle request timeout in sync group You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2877 Alternatively you

Jenkins build is back to normal : kafka_0.9.0_jdk7 #40

See

[jira] [Created] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

Andrew Winterman created KAFKA-2887: --- Summary: TopicMetadataRequest creates topic if it does not exist Key: KAFKA-2887 URL: https://issues.apache.org/jira/browse/KAFKA-2887 Project: Kafka I

Re: kafka producer and client use same groupid

Hi Surender, Please elaborate on your design Consumers don't talk to producers directly, Kafka is a brokered system, and Kafka sits between producers and consumers Also, consumers consume from partitions of a topic and producers write to partitions in a topic These partitions and the logical abstr

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

See Changes: [junrao] trivial doc fix to add link to Quotas -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu legacy-ubuntu

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15025008#comment-15025008 ] Iskandarov Eduard commented on KAFKA-2729: -- Our kafka cluster met the same issue:

kafka producer and client use same groupid

Hi all Is there anyway we can ensure in 0.8 that kafka remote producer and remote consumer work on the same groupId as my java consumer cannot consume messages from remote producer. Thanks

[GitHub] kafka pull request: KAFKA-2880: consumer should handle disconnect/...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/581 KAFKA-2880: consumer should handle disconnect/timeout for metadata requests You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAF

[jira] [Commented] (KAFKA-2880) Fetcher.getTopicMetadata NullPointerException when broker cannot be reached

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

[jira] [Created] (KAFKA-2886) WorkerSinkTask doesn't catch exceptions from rebalance callbacks

Ewen Cheslack-Postava created KAFKA-2886: Summary: WorkerSinkTask doesn't catch exceptions from rebalance callbacks Key: KAFKA-2886 URL: https://issues.apache.org/jira/browse/KAFKA-2886 Projec

Re: All brokers are running but some partitions' leader is -1

Thanks a lot Prabhjot! The issue is mitigated by running the preferred replica leader election tool! Before that, I noticed that it simply could not do leader election---when I created a new topic, that topic is not available for a long time until preferred replica leader election finishes. For th

[jira] [Created] (KAFKA-2885) Document the log4j-appender and provide examples

Grant Henke created KAFKA-2885: -- Summary: Document the log4j-appender and provide examples Key: KAFKA-2885 URL: https://issues.apache.org/jira/browse/KAFKA-2885 Project: Kafka Issue Type: Improv

[jira] [Work started] (KAFKA-2423) Introduce Scalastyle

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2423 started by Grant Henke. -- > Introduce Scalastyle > > > Key: KAFKA-2423 >

[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 ] Ismael Juma updated KAFKA-2608: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Recommend kafka_2.11 for 0.9.0.0

[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 ] Ismael Juma updated KAFKA-2608: --- Fix Version/s: 0.9.0.0 > Recommend kafka_2.11 for 0.9.0.0 on the website > ---

[ANNOUCE] Apache Kafka 0.9.0.0 Released

The Apache Kafka community is pleased to announce the release for 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 framework for data ingestion and egression, and (4) quotas. It also in

[GitHub] kafka-site pull request: Add 0.9.0.0 to downloads page

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

[GitHub] kafka-site pull request: Add 0.9.0.0 to downloads page

Github user guozhangwang commented on the pull request: https://github.com/apache/kafka-site/pull/4#issuecomment-159334264 LGTM. --- 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 e

[jira] [Created] (KAFKA-2884) Schema cache corruption in JsonConverter

Juan Hernandez created KAFKA-2884: - Summary: Schema cache corruption in JsonConverter Key: KAFKA-2884 URL: https://issues.apache.org/jira/browse/KAFKA-2884 Project: Kafka Issue Type: Bug

Re: 0.9.0.0 RC4

Thanks everyone for making the 0.9.0.0 release happen, we have 523 tickets contributed from 87 contributors in the community! Guozhang On Mon, Nov 23, 2015 at 8:49 PM, Jun Rao wrote: > Thanks everyone for voting. > > The following are the results of the votes. > > +1 binding = 4 votes (Neha Nar

Re: [kafka-clients] Re: 0.9.0.0 RC4

Thanks for everyone that contributed to this release! It has been a long time in the works with some really great new additions for folks waiting with excitement of the new consumer, security and connect (copycat) and everything else baked in. Thanks again! ~ Joe Stein - - - - - - - - - - - -

[jira] [Created] (KAFKA-2883) Improve Error Conditions in Console Consumer & Producer

Ben Stopford created KAFKA-2883: --- Summary: Improve Error Conditions in Console Consumer & Producer Key: KAFKA-2883 URL: https://issues.apache.org/jira/browse/KAFKA-2883 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-2882) Add constructor cache for Snappy and LZ4 Output/Input stream in Compressor.java

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

[jira] [Created] (KAFKA-2882) Add constructor cache for Snappy and LZ4 Output/Input stream in Compressor.java

Maksim Logvinenko created KAFKA-2882: Summary: Add constructor cache for Snappy and LZ4 Output/Input stream in Compressor.java Key: KAFKA-2882 URL: https://issues.apache.org/jira/browse/KAFKA-2882

[GitHub] kafka pull request: KAFKA-2882: Add constructor cache for Snappy a...

GitHub user logarithm opened a pull request: https://github.com/apache/kafka/pull/580 KAFKA-2882: Add constructor cache for Snappy and LZ4 Output/Input streams in Compressor.java In `wrapForOutput` and `wrapForInput` methods of `org.apache.kafka.common.record.Compressor`, `Class.f

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15024456#comment-15024456 ] Rajini Sivaram commented on KAFKA-2718: --- I think the fix is not sufficient when mult

[jira] [Assigned] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing reassigned KAFKA-2875: --- Assignee: jin xing > Class path contains multiple SLF4J bindings warnings when using scripts under >