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

See Changes: [wangguoz] KAFKA-3678: Removed sleep from streams integration tests -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker

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

See Changes: [wangguoz] KAFKA-3678: Removed sleep from streams integration tests -- [...truncated 63 lines...]

[jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305108#comment-15305108 ] Guozhang Wang commented on KAFKA-3758: -- Thanks for reporting, and we are aware of this issue:

[jira] [Commented] (KAFKA-3753) Metrics for StateStores

[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305100#comment-15305100 ] Guozhang Wang commented on KAFKA-3753: -- This is a good suggestion, and we can either implement it

[jira] [Updated] (KAFKA-3753) Metrics for StateStores

[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3753: - Labels: api (was: ) > Metrics for StateStores > --- > > Key:

[jira] [Commented] (KAFKA-3678) Fix stream integration test timeouts

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

[jira] [Resolved] (KAFKA-3678) Fix stream integration test timeouts

[ https://issues.apache.org/jira/browse/KAFKA-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3678. -- Resolution: Fixed Issue resolved by pull request 1439

[GitHub] kafka pull request: KAFKA-3678: Removed sleep

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

[jira] [Created] (KAFKA-3766) Unhandled "not enough replicas" errors in SyncGroup

Jason Gustafson created KAFKA-3766: -- Summary: Unhandled "not enough replicas" errors in SyncGroup Key: KAFKA-3766 URL: https://issues.apache.org/jira/browse/KAFKA-3766 Project: Kafka Issue

[jira] [Commented] (KAFKA-3765) Code style issues in Kafka

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

[GitHub] kafka pull request: [KAFKA-3765] Minor Code style corrections

GitHub user rekhajoshm opened a pull request: https://github.com/apache/kafka/pull/1442 [KAFKA-3765] Minor Code style corrections [KAFKA-3765] Minor Code style corrections: Removed explicit returns, not needed parentheses, corrected variables, removed unused imports You can

[jira] [Created] (KAFKA-3765) Code style issues in Kafka

Rekha Joshi created KAFKA-3765: -- Summary: Code style issues in Kafka Key: KAFKA-3765 URL: https://issues.apache.org/jira/browse/KAFKA-3765 Project: Kafka Issue Type: Improvement

Kafka/Samza meetup at LinkedIn, June 15, 6pm

[bcc: us...@kafka.apache.org, dev@kafka.apache.org] Hi everyone, We would like to invite you to our first Stream Processing Meetup at LinkedIn on June 15 at 6pm. Please RSVP here: http://www.meetup.com/Stream-Processing-Meetup-LinkedIn/events/231454378 Going forward (at LinkedIn) we will host

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

See Changes: [junrao] KAFKA-3682; ArrayIndexOutOfBoundsException thrown by -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu

[jira] [Commented] (KAFKA-3763) Remove deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304974#comment-15304974 ] Ismael Juma commented on KAFKA-3763: Sure, but note that this is planned for 0.11.0 and the next

[jira] [Commented] (KAFKA-3763) Remove deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304973#comment-15304973 ] Amey commented on KAFKA-3763: - [~ijuma] I can work on this Jira, would you mind If I take this up > Remove

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

See Changes: [junrao] KAFKA-3682; ArrayIndexOutOfBoundsException thrown by -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu

[jira] [Commented] (KAFKA-3682) ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full

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

[jira] [Resolved] (KAFKA-3682) ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full

[ https://issues.apache.org/jira/browse/KAFKA-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-3682. Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1352

[GitHub] kafka pull request: KAFKA-3682 ArrayIndexOutOfBoundsException thro...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1352 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

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

See Changes: [ismael] MINOR: Fix a couple of scaladoc typos -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu

[GitHub] kafka pull request: MINOR: Remove synchronized as the tasks are ex...

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1441 MINOR: Remove synchronized as the tasks are executed sequentially You can merge this pull request into a Git repository by running: $ git pull https://github.com/Ishiihara/kafka

Build failed in Jenkins: kafka-0.10.0-jdk7 #110

See Changes: [ismael] MINOR: Fix tracing in KafkaApis.handle() -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (docker Ubuntu ubuntu

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

See Changes: [ismael] MINOR: Fix tracing in KafkaApis.handle() [ismael] MINOR: Fix a couple of scaladoc typos -- [...truncated 63 lines...]

[GitHub] kafka pull request: MINOR: Fix a couple of typos

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

[jira] [Commented] (KAFKA-3764) Error processing append operation on partition

[ https://issues.apache.org/jira/browse/KAFKA-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304742#comment-15304742 ] Ismael Juma commented on KAFKA-3764: Is there any chance you could test with a different client

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

See Changes: [ismael] MINOR: Fix tracing in KafkaApis.handle() -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu

[GitHub] kafka pull request: MINOR: Fix tracing in KafkaApis.handle()

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

[jira] [Created] (KAFKA-3764) Error processing append operation on partition

Martin Nowak created KAFKA-3764: --- Summary: Error processing append operation on partition Key: KAFKA-3764 URL: https://issues.apache.org/jira/browse/KAFKA-3764 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-58 - Make Log Compaction Point Configurable

Hey, its been over 3 days since the vote started and we clearly have over 3 +1s. Eric, Feel free to close the vote and we can move to code reviews :) Gwen On Fri, May 27, 2016 at 8:08 AM, Jun Rao wrote: > Thanks for the proposal. +1 > > Jun > > On Tue, May 24, 2016 at 1:37

Re: [DISCUSS] KIP-55: Secure quotas for authenticated users

Jun, Thank you for the review and the suggestions. I have updated the KIP with the changes you suggested. On Fri, May 27, 2016 at 5:24 PM, Jun Rao wrote: > Rajini, > > Thanks for the updated KIP. Looks good overall. Just a few minor comments. > > 10. For quota related

[jira] [Assigned] (KAFKA-3762) Log.loadSegments() should log the message in exception

[ https://issues.apache.org/jira/browse/KAFKA-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3762: - Assignee: Ishita Mandhan > Log.loadSegments() should log the message in exception >

[jira] [Commented] (KAFKA-3561) Auto create through topic for KStream aggregation and join

[ https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304347#comment-15304347 ] Guozhang Wang commented on KAFKA-3561: -- Hi [~damianguy] a couple thoughts: 1. Topics referenced in

Re: KAFKA-3722 : Discussion about custom PrincipalBuilder and Authorizer configs

Cool. I will upload a patch for this. Thanks, Mayuresh On Fri, May 27, 2016 at 12:35 AM, Harsha wrote: > Mayuresh & Ismael, >Agree on not breaking interfaces on public API. >+1 on option 2. > Thanks, > Harsha > > On Mon, May 23,

Re: [DISCUSS] KIP-55: Secure quotas for authenticated users

Rajini, Thanks for the updated KIP. Looks good overall. Just a few minor comments. 10. For quota related metric names, currently, they already have a tag "client-d". It seems that we can just replace it with a similar tag "user" if quota.type is user. The sensor names only have the client-id

[GitHub] kafka pull request: MINOR: Fix a couple of typos

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/1440 MINOR: Fix a couple of typos You can merge this pull request into a Git repository by running: $ git pull https://github.com/vahidhashemian/kafka typo06/fix_typos_in_code_comments

[jira] [Work started] (KAFKA-3678) Fix stream integration test timeouts

[ https://issues.apache.org/jira/browse/KAFKA-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3678 started by Eno Thereska. --- > Fix stream integration test timeouts > > >

[jira] [Commented] (KAFKA-3678) Fix stream integration test timeouts

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

[GitHub] kafka pull request: KAFKA-3678: Removed sleep

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1439 KAFKA-3678: Removed sleep You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3678-timeouts1 Alternatively you can

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304224#comment-15304224 ] Eno Thereska commented on KAFKA-3637: - It turns out it might not make sense to have an "initialised"

[jira] [Resolved] (KAFKA-3637) Add method that checks if streams are initialised

[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3637. - Resolution: Won't Fix > Add method that checks if streams are initialised >

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304171#comment-15304171 ] Eno Thereska commented on KAFKA-3637: - Hi [~tszym]. I just added a method that might help with that as

Re: [VOTE] KIP-58 - Make Log Compaction Point Configurable

Thanks for the proposal. +1 Jun On Tue, May 24, 2016 at 1:37 PM, Eric Wasserman wrote: > Hi, > > I would like to begin voting on KIP-58 - Make Log Compaction Point > Configurable > > KIP-58 is here: < > >

[GitHub] kafka pull request: MINOR: Kafka And ZooKeeper Stop Scripts doesn'...

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/1438 MINOR: Kafka And ZooKeeper Stop Scripts doesn't return PID In Centos 6.5, 'ps -ax | grep java' command doesn't returns the full process name. So, the command doesn't returns the PID even Kafka

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

See Changes: [ismael] KAFKA-3749; fix "BOOSTRAP_SERVERS_DOC" typo -- [...truncated 63 lines...]

[jira] [Commented] (KAFKA-3561) Auto create through topic for KStream aggregation and join

[ https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303877#comment-15303877 ] Damian Guy commented on KAFKA-3561: --- Guozhang - i'd like to do this if it is ok with you. I'm going to

[jira] [Assigned] (KAFKA-3561) Auto create through topic for KStream aggregation and join

[ https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3561: - Assignee: Damian Guy > Auto create through topic for KStream aggregation and join >

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

See Changes: [ismael] KAFKA-3749; fix "BOOSTRAP_SERVERS_DOC" typo -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu

[jira] [Updated] (KAFKA-3749) "BOOSTRAP_SERVERS_DOC" typo in CommonClientConfigs

[ https://issues.apache.org/jira/browse/KAFKA-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3749: --- Assignee: Manu Zhang > "BOOSTRAP_SERVERS_DOC" typo in CommonClientConfigs >

[jira] [Resolved] (KAFKA-3749) "BOOSTRAP_SERVERS_DOC" typo in CommonClientConfigs

[ https://issues.apache.org/jira/browse/KAFKA-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3749. Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 0.10.1.0 >

[GitHub] kafka pull request: KAFKA-3749, fix "BOOSTRAP_SERVERS_DOC" typo

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

[jira] [Commented] (KAFKA-3749) "BOOSTRAP_SERVERS_DOC" typo in CommonClientConfigs

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

Re: Kafka server contains messages but consumer cannot receive any(Producer used compression.type = snappy)

Hi Jason, I'm so sorry to reply your email later. Your solution solved my issue. When I use "earliest" for auto.offset.reset, the consumer can receiver messages. Thanks a lot, Nicole On Thu, May 26, 2016 at 11:21 AM, Jason Gustafson wrote: > Hi Nicole, > > It would help

Re: [HEADS-UP] Modification to KIP Template

Hi Gwen, Thanks for adding the "Test Plans" section. I think it may be worth adding a note about performance testing plans too (whenever relevant). By the way, even though the following page has the new section, if I use `Create -> KIP-Template`, the new section doesn't appear. Do you know why?

[jira] [Created] (KAFKA-3763) Remove deprecated APIs

Ismael Juma created KAFKA-3763: -- Summary: Remove deprecated APIs Key: KAFKA-3763 URL: https://issues.apache.org/jira/browse/KAFKA-3763 Project: Kafka Issue Type: Task Reporter:

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

See Changes: [me] MINOR: Delete unused code in FileStreamSourceTask -- [...truncated 3936 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[5] PASSED

Re: KAFKA-3722 : Discussion about custom PrincipalBuilder and Authorizer configs

Mayuresh & Ismael, Agree on not breaking interfaces on public API. +1 on option 2. Thanks, Harsha On Mon, May 23, 2016, at 10:30 AM, Mayuresh Gharat wrote: > Hi Harsha and Ismael, > > Option 2 sounds like a good idea if we want to make this quick

[jira] [Commented] (KAFKA-3744) Message format needs to identify serializer

[ https://issues.apache.org/jira/browse/KAFKA-3744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303666#comment-15303666 ] Ewen Cheslack-Postava commented on KAFKA-3744: -- Just to second [~ijuma]'s comments, this

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

See Changes: [me] MINOR: Delete unused code in FileStreamSourceTask -- [...truncated 40 lines...] :examples:clean :log4j-appender:clean :streams:clean :tools:clean :connect:api:clean

[GitHub] kafka pull request: delete unused code

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

[jira] [Commented] (KAFKA-3761) Controller has RunningAsBroker instead of RunningAsController state

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