Build failed in Jenkins: kafka-1.1-jdk7 #85

See Changes: [me] KAFKA-6661: Ensure sink connectors don’t resume consumer when task is -- [...truncated 1.89 MB...] java.lang.NullPointerException at hudson.plugins.

Re: Streams meetup@LinkedIn (Mar 21)

Bump. We are going to have the following talks: 6:35-7:10 PM: Apache Pulsar - The next generation messaging system (Karthik Ramasamy, Co-Founder at Streamlio) 7:15-7:50 PM: Conquering the Lambda architecture in LinkedIn metrics platform with Apache Calcite and Apache Samza (Khai Tran, Staff Softwa

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

See

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

See Changes: [github] KAFKA-6656; Config tool should return non-zero status code on failure [wangguoz] MINOR: Fix incorrect expression for KTable in stream doc. (#4718) [mjsax] KAFKA-6106: Postpone normal proce

Jenkins build is back to normal : kafka-trunk-jdk9 #481

See

Build failed in Jenkins: kafka-1.1-jdk7 #84

See Changes: [matthias] KAFKA-6106: Postpone normal processing of tasks within a thread until -- [...truncated 1.89 MB...] java.lang.NullPointerException at hudson.pl

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

See Changes: [wangguoz] MINOR: Fix incorrect expression for KTable in stream doc. (#4718) [mjsax] KAFKA-6106: Postpone normal processing of tasks within a thread until --

Build failed in Jenkins: kafka-0.10.2-jdk7 #205

See Changes: [me] KAFKA-6661: Ensure sink connectors don’t resume consumer when task is -- Started by an SCM change [EnvInject] - Loading node environment variables. Build

Build failed in Jenkins: kafka-0.10.1-jdk7 #132

See Changes: [me] KAFKA-6661: Ensure sink connectors don’t resume consumer when task is -- Started by an SCM change [EnvInject] - Loading node environment variables. Build

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

See Changes: [me] KAFKA-6661: Ensure sink connectors don’t resume consumer when task is -- Started by an SCM change [EnvInject] - Loading node environment variables. Build

[jira] [Created] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

Srinivas Dhruvakumar created KAFKA-: --- Summary: OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions Key: KAFKA- URL: https://issues.apache.org/jira/browse/KAFKA-6

[VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position

Hi all, Since there does not seem to be too much discussion in KIP-266, I will be starting a voting thread. Here is the link to KIP-266 for reference: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75974886 Recently, I have made some updates to the KIP. To reiterate, I have in

Re: [DISCUSS] KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade

Hello Matthias, thanks for the KIP. Here are some comments: 1. "For all other instances the leader sends a regular Assignment in version X back." Does that mean the leader will exclude any member of the group whose protocol version that it does not understand? For example, if we have A, B, C with

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

See Changes: [rajinisivaram] MINOR: Avoid nulls when deserializing Trogodor JSON (#4688) -- [...truncated 3.55 MB...] org.apache.kafka.streams.StreamsConfigTest > should

[jira] [Resolved] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6106. Resolution: Fixed > Postpone normal processing of tasks within a thread until restoration of

Build failed in Jenkins: kafka-trunk-jdk9 #480

See Changes: [wangguoz] MINOR: Fix incorrect expression for KTable in stream doc. (#4718) [mjsax] KAFKA-6106: Postpone normal processing of tasks within a thread until --

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

See Changes: [github] KAFKA-6656; Config tool should return non-zero status code on failure -- [...truncated 1.53 MB...] org.apache.kafka.streams.integration.KStreamsFine

Re: Subject: [VOTE] 1.1.0 RC3

Hello again, Ran through our regression and performance suite. Everything checks out. Small note, release notes say ZK 3.4.11 is included (KAFKA-6390), but this was reverted in https://github.com/apache/kafka/pull/4678 as a MINOR commit. In any case, +1 (non-binding). Thanks, Jeff Heroku On Thu,

[jira] [Created] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

Dmitry Konstantinov created KAFKA-6665: -- Summary: LeaderChangeListener.handleDataDeleted deadlock Key: KAFKA-6665 URL: https://issues.apache.org/jira/browse/KAFKA-6665 Project: Kafka Iss

Re: Add me to the contributor list

Hi Jun, I looked for spark committers mailing list but couldn't find one. Could you please advise me how to get permission from the spark committers ? Thanks, Sirisha Sindiri On Wed, Mar 14, 2018 at 4:00 PM, Sirisha Sindiri wrote: > Sure Thank you!! > > On Wed, Mar 14, 2018 at 3:51 PM, Jun Rao

Jenkins build is back to normal : kafka-1.0-jdk7 #169

See

Re: Request for permission to create a KIP

Hello Debasish, I have added you to the list. Cheers. Guozhang On Thu, Mar 15, 2018 at 10:29 AM, Debasish Ghosh < debasish.gh...@lightbend.com> wrote: > Hello - > > My registered email in Confluence is debasish.gh...@lightbend.com. I > request for permission to create a KIP page in Kafka. Is t

Request for permission to create a KIP

Hello - My registered email in Confluence is debasish.gh...@lightbend.com. I request for permission to create a KIP page in Kafka. Is this the right place to request one ? Thanks. -- Debasish Ghosh Principal Engineer Twitter: @debasishg Blog: http://debasishg.blogspot.com Code: https://github.

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Thanks, Jun. 11. updatePartitionMetadata() provides all partitions with their leaders so that callbacks that scale down quotas based on fraction of partitions hosted on each broker may compute the scaling factor. Callbacks that scale up quotas based on the partition count hosted on each broker can

[DISCUSS] KIP-269: Substitution Within Configuration Values

Hi everyone. I created KIP-269: Substitution Within Configuration Values (https://cwiki.apache.org/confluence/display/KAFKA/KIP+ 269+Substitution+Within+Configuration+Values

Re: Add to contributor list

Done. :) -Matthias On 3/15/18 9:16 AM, Ron Dagostino wrote: > << Hello. Could someone please add me to the contributor list? My JIRA login > is rndgstn. > > Thanks, > > Ron Dagostino > signature.asc Description: OpenPGP digital signature

Re: Request permission to create KIP

Done. You should be able to edit the Wiki and create new pages now. -Matthias On 3/15/18 9:44 AM, Sergey Korytnikov wrote: > Hi, > > I would like to create KIP in wiki, could you please grant a permission for > my id? > id: ssbiox > > Thanks, > Sergey > signature.asc Description: OpenPGP d

[jira] [Created] (KAFKA-6664) KIP-270 Substitution Within Configuration Values

Ron Dagostino created KAFKA-6664: Summary: KIP-270 Substitution Within Configuration Values Key: KAFKA-6664 URL: https://issues.apache.org/jira/browse/KAFKA-6664 Project: Kafka Issue Type: Im

[jira] [Resolved] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

[ https://issues.apache.org/jira/browse/KAFKA-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6656. Resolution: Fixed Fix Version/s: 1.2.0 > Use non-zero status code when kafka-configs.

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Hi, Rajini, Thanks for the explanation. It makes sense. 11. We probably want to clarify in the interface that every time when updatePartitionMetadata() is called, the full list of partitions whose leader is on this broker will be passed in? Jun On Thu, Mar 15, 2018 at 4:42 AM, Rajini Sivaram w

Re: Subject: [VOTE] 1.1.0 RC3

+1 Ran test suite which passed. Checked signatures. On Thu, Mar 15, 2018 at 7:50 AM, Damian Guy wrote: > Hello Kafka users, developers and client-developers, > > This is the fourth candidate for release of Apache Kafka 1.1.0. > > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId

[jira] [Reopened] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6655: > CleanupThread] Failed to lock the state directory due to an unexpected > exception >

Request permission to create KIP

Hi, I would like to create KIP in wiki, could you please grant a permission for my id? id: ssbiox Thanks, Sergey

Add to contributor list

<<

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

See Changes: [jason] KAFKA-6653; Complete delayed operations even when there is lock -- [...truncated 3.51 MB...] kafka.api.SaslPlainSslEndToEndAuthorizationTest > testNo

Subject: [VOTE] 1.1.0 RC3

Hello Kafka users, developers and client-developers, This is the fourth candidate for release of Apache Kafka 1.1.0. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75957546 A few highlights: * Significant Controller improvements (much faster and session expiration edge cases f

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

See Changes: [rajinisivaram] MINOR: Avoid nulls when deserializing Trogodor JSON (#4688) -- [...truncated 415.97 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > sho

Jenkins build is back to normal : kafka-1.1-jdk7 #82

See

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Hi Jun, 12. Sorry, I had to revert the change that removed ` ClientQuotaCallback.quotaLimit()`. We are allowing quota callbacks to use custom metric tags. For each request, quota manager uses ` ClientQuotaCallback.quota()` to map (user-principal, client-id) to the metric tags that determine which

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

See Changes: [jason] KAFKA-6653; Complete delayed operations even when there is lock -- [...truncated 1.53 MB...] org.apache.kafka.streams.integration.KStreamsFineGrained

[jira] [Created] (KAFKA-6663) Expression for GlobalKTable is not correct

huxihx created KAFKA-6663: - Summary: Expression for GlobalKTable is not correct Key: KAFKA-6663 URL: https://issues.apache.org/jira/browse/KAFKA-6663 Project: Kafka Issue Type: Bug Componen

Build failed in Jenkins: kafka-1.1-jdk7 #81

See Changes: [jason] KAFKA-6653; Complete delayed operations even when there is lock -- [...truncated 415.27 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldRetai

Re: [VOTE] 1.1.0 RC2

Hi All, I'm going to close this vote thread as there has been another blocker merged to 1.1. I'll create another RC later today. Thanks, Damian On Thu, 15 Mar 2018 at 03:31 Satish Duggana wrote: > +1 (non-binding) > > - Ran testAll/releaseTarGzAll on 1.1.0-RC2 tag > - Ran through quickstart of

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hi Jun, thank you for following me on these thoughts. It was important to me to feel that kind of understanding for my arguments. What I was hoping for (I mentioned this earlier) is that we can model the case where we do not want to copy the data the exact same way as the case when we do cop

[jira] [Resolved] (KAFKA-6653) Delayed operations may not be completed when there is lock contention

[ https://issues.apache.org/jira/browse/KAFKA-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6653. Resolution: Fixed Fix Version/s: 1.1.0 > Delayed operations may not be completed when