[jira] [Created] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong

2019-01-15 Thread Lars Francke (JIRA)
Lars Francke created KAFKA-7822: --- Summary: Kafka Log Implementation picture in the documentation is wrong Key: KAFKA-7822 URL: https://issues.apache.org/jira/browse/KAFKA-7822 Project: Kafka I

[jira] [Created] (KAFKA-7823) Missing release notes pages

2019-01-15 Thread Viktor Somogyi (JIRA)
Viktor Somogyi created KAFKA-7823: - Summary: Missing release notes pages Key: KAFKA-7823 URL: https://issues.apache.org/jira/browse/KAFKA-7823 Project: Kafka Issue Type: Improvement Affec

Re: [VOTE] KIP-379: Multiple Consumer Group Management

2019-01-15 Thread Alex D
Hello guys, 2 votes from Jason, Gwen Any binding votes? Hello M Manna, If migrating to JSON makes sense, you can post a new KIP for this purpose. Thanks, Alex Dunayevsky On Tue, 15 Jan 2019, 04:24 Jason Gustafson +1 Thanks for the KIP! > > -Jason > > On Mon, Jan 14, 2019 at 5:15 PM Gwen Shapi

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Rajini Sivaram
Thanks, Harsha! If there are no other concerns, I will start the vote later today. On Mon, Jan 14, 2019 at 6:04 PM Harsha wrote: > +1 to include in 2.2. Thanks Rajini for sharing the details. > > On Mon, Jan 14, 2019, at 9:10 AM, Rajini Sivaram wrote: > > This is the result of the tests Gardner

Re: [VOTE] - KIP-213 (new vote) - Simplified and revised.

2019-01-15 Thread Adam Bellemare
If I can get one more binding vote in here, I may be able to get this out for the 2.2 release in February. Currently at: 2 binding, 4 non-binding. On Sun, Jan 13, 2019 at 2:41 PM Patrik Kleindl wrote: > +1 (non-binding) > I have followed the discussion too and think this feature will be very

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Jan Filipiak
> The connection queue for Processors will be changed to ArrayBlockingQueue > with a fixed size of 20. Acceptor will use round-robin allocation to allocate > each new connection to the next available Processor to which the connection > can be added without blocking. If a Processor's queue is f

Re: [VOTE] KIP-379: Multiple Consumer Group Management

2019-01-15 Thread Damian Guy
+1 (binding) thanks On Tue, 15 Jan 2019 at 09:43, Alex D wrote: > Hello guys, > > 2 votes from Jason, Gwen > Any binding votes? > > > Hello M Manna, > If migrating to JSON makes sense, you can post a new KIP for this purpose. > > Thanks, > Alex Dunayevsky > > On Tue, 15 Jan 2019, 04:24 Jason Gus

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Rajini Sivaram
Hi Jan, If the queue of one Processor is full, we move to the next Processor immediately without blocking. So as long as the queue of any Processor is not full, we accept the connection immediately. If the queue of all Processors are full, we assign a Processor and block until the connection can b

[ANNOUNCE] Apache Roadshow Chicago, Call for Presentations

2019-01-15 Thread Trevor Grant
Hello Devs! You're receiving this email because you are subscribed to one or more Apache developer email lists. I’m writing to let you know about an exciting event coming to the Chicago area: The Apache Roadshow Chicago. It will be held May 13th and 14th at three bars in the Logan Square neighb

Re: [VOTE] KIP-379: Multiple Consumer Group Management

2019-01-15 Thread Vahid Hashemian
+1. Thanks for the KIP. --Vahid On Tue, Jan 15, 2019, 04:13 Damian Guy wrote: > +1 (binding) thanks > > On Tue, 15 Jan 2019 at 09:43, Alex D wrote: > > > Hello guys, > > > > 2 votes from Jason, Gwen > > Any binding votes? > > > > > > Hello M Manna, > > If migrating to JSON makes sense, you can

[jira] [Resolved] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

2019-01-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7391. Resolution: Fixed Fix Version/s: 2.2.0 > Introduce close(Duration) to Producer and A

Re: [VOTE] - KIP-213 (new vote) - Simplified and revised.

2019-01-15 Thread Matthias J. Sax
I'll try to review the KIP before the deadline, but as I am acting as release manager and also working on KIP-258, I cannot promise. Even if we make the voting deadline, it might also be tight to review the PR, as it seems to be big and complicated. I'll try my very best to get it into 2.2... -M

[jira] [Created] (KAFKA-7824) Require member.id for initial join group request

2019-01-15 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7824: -- Summary: Require member.id for initial join group request Key: KAFKA-7824 URL: https://issues.apache.org/jira/browse/KAFKA-7824 Project: Kafka Issue Type: Improv

WIKI permission for tdanylchuk

2019-01-15 Thread Taras Danylchuk
Hello, I would like to have a permission to create KIP ( https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals#KafkaImprovementProposals-DiscardedKIPs ). My account details: https://cwiki.apache.org/confluence/display/~tdanylchuk BR, Taras Danylchuk. Phone: +38 (068) 206-

Re: WIKI permission for tdanylchuk

2019-01-15 Thread Jun Rao
Hi, Taras, Thanks for your interest. Just gave you the wiki permission. Jun On Tue, Jan 15, 2019 at 9:47 AM Taras Danylchuk wrote: > Hello, > > I would like to have a permission to create KIP ( > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals#KafkaImprovementPr

Re: WIKI permission for tdanylchuk

2019-01-15 Thread Taras Danylchuk
Great, thanks! On Tue, Jan 15, 2019, 20:01 Jun Rao Hi, Taras, > > Thanks for your interest. Just gave you the wiki permission. > > Jun > > On Tue, Jan 15, 2019 at 9:47 AM Taras Danylchuk > wrote: > >> Hello, >> >> I would like to have a permission to create KIP ( >> >> https://cwiki.apache.org/c

[jira] [Created] (KAFKA-7825) Kafka MirrorMaker crashes unexpectedly

2019-01-15 Thread Joe Devilla (JIRA)
Joe Devilla created KAFKA-7825: -- Summary: Kafka MirrorMaker crashes unexpectedly Key: KAFKA-7825 URL: https://issues.apache.org/jira/browse/KAFKA-7825 Project: Kafka Issue Type: Bug Co

Re: [VOTE] KIP-349 Priorities for Source Topics

2019-01-15 Thread Colin McCabe
On Sun, Jan 13, 2019, at 18:13, n...@afshartous.com wrote: > Thanks Colin and Mathias. > > > On Jan 12, 2019, at 8:27 PM, Matthias J. Sax wrote: > > > > Thus, I would suggest to limit this KIP to the consumer only, otherwise, > > the scope will be too large and this KIP will drag on even longer.

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

2019-01-15 Thread Apache Jenkins Server
See Changes: [jason] KAFKA-7391; Introduce close(Duration) to Producer and AdminClient -- [...truncated 2.26 MB...] org.apache.kafka.streams.test.OutputVerifierTest > sh

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Colin McCabe
Hi Rajini, Thanks for this. The KIP looks really useful. > > A new metric will be added to track the amount of time Acceptor is blocked > from accepting connections due to backpressure. This will be a yammer > Meter, consistent with other SocketServer metrics. > > kafka.network:type=Accepto

[DISCUSS] 2.1.1 bug-fix release

2019-01-15 Thread Colin McCabe
Hi all, I'd like to volunteer to be the release manager for the 2.1.1 bug fix release. 2.1 was released November 20, 2018. There are 34 fixes scheduled for inclusion in 2.1.1 so far. Please find all the resolved tickets here: https://issues.apache.org/jira/browse/KAFKA-7818?jql=project%20%3D%2

Build failed in Jenkins: kafka-trunk-jdk11 #215

2019-01-15 Thread Apache Jenkins Server
See Changes: [jason] KAFKA-7391; Introduce close(Duration) to Producer and AdminClient -- [...truncated 2.27 MB...] kafka.utils.SchedulerTest > testPeriodicTask PASSED k

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Ismael Juma
I think the point is that we distribute the time more fairly between connection handling and other operations where before we could block on the TLS handshake for a long time given a large number of connections. Ismael On Tue, Jan 15, 2019 at 11:39 AM Colin McCabe wrote: > Hi Rajini, > > Thanks

Re: [DISCUSS] 2.1.1 bug-fix release

2019-01-15 Thread Ismael Juma
Thanks for volunteering Colin. There are some important fixes since 2.1.0 so I think this would be great. Ismael On Tue, Jan 15, 2019 at 11:50 AM Colin McCabe wrote: > Hi all, > > I'd like to volunteer to be the release manager for the 2.1.1 bug fix > release. > > 2.1 was released November 20,

[jira] [Created] (KAFKA-7826) Connect Standalone System tests are failing

2019-01-15 Thread Magesh kumar Nandakumar (JIRA)
Magesh kumar Nandakumar created KAFKA-7826: -- Summary: Connect Standalone System tests are failing Key: KAFKA-7826 URL: https://issues.apache.org/jira/browse/KAFKA-7826 Project: Kafka

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Rajini Sivaram
Hi Colin, `AcceptorIdlePercent` indicates the total amount of time the acceptor is inactive and not accepting any connections because it is blocked on Processors. But I agree the name could be improved. There is back pressure at the Java level (which we can't monitor) and back pressure we apply wi

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Colin McCabe
On Tue, Jan 15, 2019, at 12:59, Rajini Sivaram wrote: > Hi Colin, > > `AcceptorIdlePercent` indicates the total amount of time the acceptor is > inactive and not accepting any connections because it is blocked on > Processors. But I agree the name could be improved. There is back pressure > at the

[jira] [Resolved] (KAFKA-7824) Require member.id for initial join group request

2019-01-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7824. Resolution: Fixed Fix Version/s: 2.2.0 > Require member.id for initial join group re

[jira] [Created] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed

2019-01-15 Thread Somnath Choudhuri (JIRA)
Somnath Choudhuri created KAFKA-7827: Summary: Consumer stops receiving messages when FIRST leader started is killed Key: KAFKA-7827 URL: https://issues.apache.org/jira/browse/KAFKA-7827 Project:

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Rajini Sivaram
Thanks Colin. I have updated the KIP. On Tue, Jan 15, 2019 at 9:20 PM Colin McCabe wrote: > On Tue, Jan 15, 2019, at 12:59, Rajini Sivaram wrote: > > Hi Colin, > > > > `AcceptorIdlePercent` indicates the total amount of time the acceptor is > > inactive and not accepting any connections because

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

2019-01-15 Thread Apache Jenkins Server
See Changes: [github] MINOR: Add log entry for KafkaException in StreamThread#runLoop (#6144) [github] MINOR: Streams upgrade guide section for newly merged KIPs (#6108)

Re: [VOTE] KIP-414: Expose Embedded ClientIds in Kafka Streams

2019-01-15 Thread Guozhang Wang
+1 from myself. Thanks for everyone for the feedbacks / votes. I'm closing this voting thread with 3 binding votes (Damian, Matthias, Guozhang) and 3 non-binding votes (John, Bill, Boyang). Guozhang On Sun, Jan 13, 2019 at 11:42 AM Guozhang Wang wrote: > Hello Matthias, > > I added here sinc

Re: [VOTE] - KIP-213 (new vote) - Simplified and revised.

2019-01-15 Thread Adam Bellemare
All good Matthias. If it doesn’t get in for 2.2 I’ll just do it for the next release. Thanks > On Jan 15, 2019, at 12:25 PM, Matthias J. Sax wrote: > > I'll try to review the KIP before the deadline, but as I am acting as > release manager and also working on KIP-258, I cannot promise. Even i

Build failed in Jenkins: kafka-trunk-jdk11 #216

2019-01-15 Thread Apache Jenkins Server
See Changes: [github] MINOR: Add log entry for KafkaException in StreamThread#runLoop (#6144) [github] MINOR: Streams upgrade guide section for newly merged KIPs (#6108)

[ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Jason Gustafson
Hi All, The PMC for Apache Kafka has invited Vahid Hashemian as a project committer and we are pleased to announce that he has accepted! Vahid has made numerous contributions to the Kafka community over the past few years. He has authored 13 KIPs with core improvements to the consumer and the too

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Rajini Sivaram
Congratulations, Vahid! Well deserved!! Regards, Rajini On Tue, Jan 15, 2019 at 10:45 PM Jason Gustafson wrote: > Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contr

Kafka official docker image

2019-01-15 Thread Олег Иванов
Hi, Could you please create an official docker image of kafka? There are a lot custom images in the dockerhub, but company's security policy allows only official images. Thanks!

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Jun Rao
Congratulations, Vahid. Thanks, Jun On Tue, Jan 15, 2019 at 2:45 PM Jason Gustafson wrote: > Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contributions to the Kafka

Re: Kafka official docker image

2019-01-15 Thread Stevo Slavić
FYI https://docs.confluent.io/current/installation/docker/docs/image-reference.html On Wed, Jan 16, 2019 at 12:06 AM Олег Иванов wrote: > Hi, > > Could you please create an official docker image of kafka? There are a lot > custom images in the dockerhub, but company's security policy allows only

Re: Kafka official docker image

2019-01-15 Thread M. Manna
There should be confluent enterprise image-it should work without control centre etc. and basic open source items should stay the same. Could you kindly check ? On Tue, 15 Jan 2019 at 23:06, Олег Иванов wrote: > Hi, > > Could you please create an official docker image of kafka? There are a lot

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Boyang Chen
This is exciting moment! Congrats Vahid! Boyang From: Rajini Sivaram Sent: Wednesday, January 16, 2019 6:50 AM To: Users Cc: dev Subject: Re: [ANNOUNCE] New Committer: Vahid Hashemian Congratulations, Vahid! Well deserved!! Regards, Rajini On Tue, Jan 15, 201

[VOTE] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Rajini Sivaram
Hi all, I would like to start vote on KIP-402 to improve fairness in channel processing in SocketServer to protect brokers from connection storms and limit the total number of connections in brokers to avoid OOM. The KIP is here: - https://cwiki.apache.org/confluence/display/KAFKA/KIP-402%

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Matthias J. Sax
Congrats! On 1/15/19 3:34 PM, Boyang Chen wrote: > This is exciting moment! Congrats Vahid! > > Boyang > > > From: Rajini Sivaram > Sent: Wednesday, January 16, 2019 6:50 AM > To: Users > Cc: dev > Subject: Re: [ANNOUNCE] New Committer: Vahid Hashemian > > Cong

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Mayuresh Gharat
congrats !! On Tue, Jan 15, 2019 at 3:42 PM Matthias J. Sax wrote: > Congrats! > > On 1/15/19 3:34 PM, Boyang Chen wrote: > > This is exciting moment! Congrats Vahid! > > > > Boyang > > > > > > From: Rajini Sivaram > > Sent: Wednesday, January 16, 2019 6:50 AM >

Re: [VOTE] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Harsha
+1 (binding). Thanks, Harsha On Tue, Jan 15, 2019, at 3:38 PM, Rajini Sivaram wrote: > Hi all, > > I would like to start vote on KIP-402 to improve fairness in channel > processing in SocketServer to protect brokers from connection storms and > limit the total number of connections in brokers to

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Harsha
Congrats!! -Harsha On Tue, Jan 15, 2019, at 4:00 PM, Mayuresh Gharat wrote: > congrats !! > > On Tue, Jan 15, 2019 at 3:42 PM Matthias J. Sax > wrote: > > > Congrats! > > > > On 1/15/19 3:34 PM, Boyang Chen wrote: > > > This is exciting moment! Congrats Vahid! > > > > > > Boyang > > > > > > ___

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

2019-01-15 Thread Apache Jenkins Server
See Changes: [colin] KAFKA-7792: Add simple /agent/uptime and /coordinator/uptime health [jason] KAFKA-7824; Require member.id for initial join group request [KIP-394] --

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Bill Bejeck
Congratulations! On Tue, Jan 15, 2019 at 7:08 PM Harsha wrote: > Congrats!! > -Harsha > > On Tue, Jan 15, 2019, at 4:00 PM, Mayuresh Gharat wrote: > > congrats !! > > > > On Tue, Jan 15, 2019 at 3:42 PM Matthias J. Sax > > wrote: > > > > > Congrats! > > > > > > On 1/15/19 3:34 PM, Boyang Chen w

[VOTE] KIP-258: Allow to Store Record Timestamps in RocksDB

2019-01-15 Thread Matthias J. Sax
Hi, I would like to start the vote for KIP-258: https://cwiki.apache.org/confluence/display/KAFKA/KIP-258%3A+Allow+to+Store+Record+Timestamps+in+RocksDB The KIP adds new stores that allow to store record timestamps next to key and value. Additionally, we will allow to upgrade exiting stores to t

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread James Cheng
Congrats, Vahid!! -James > On Jan 15, 2019, at 2:44 PM, Jason Gustafson wrote: > > Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project committer > and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contributions to the Kafka communi

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Yishun Guan
Congratulations! On Tue, Jan 15, 2019, 16:46 James Cheng wrote: > Congrats, Vahid!! > > -James > > > On Jan 15, 2019, at 2:44 PM, Jason Gustafson wrote: > > > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > > we are > > pleased to announce t

Build failed in Jenkins: kafka-trunk-jdk11 #217

2019-01-15 Thread Apache Jenkins Server
See Changes: [colin] KAFKA-7792: Add simple /agent/uptime and /coordinator/uptime health [jason] KAFKA-7824; Require member.id for initial join group request [KIP-394] --

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Satish Duggana
Congratulations Vahid! On Tue, Jan 15, 2019 at 5:47 PM Yishun Guan wrote: > > Congratulations! > > On Tue, Jan 15, 2019, 16:46 James Cheng wrote: > > > Congrats, Vahid!! > > > > -James > > > > > On Jan 15, 2019, at 2:44 PM, Jason Gustafson wrote: > > > > > > Hi All, > > > > > > The PMC for Apac

[jira] [Created] (KAFKA-7828) Add Trogdor ExternalCommandSpec and ExternalCommandWorker

2019-01-15 Thread Xi Yang (JIRA)
Xi Yang created KAFKA-7828: -- Summary: Add Trogdor ExternalCommandSpec and ExternalCommandWorker Key: KAFKA-7828 URL: https://issues.apache.org/jira/browse/KAFKA-7828 Project: Kafka Issue Type: Impro

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Ismael Juma
Congratulations Vahid! On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contributions to the Kafka community over the past >

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Manikumar
Congrats, Vahid! On Wed 16 Jan, 2019, 6:53 AM Ismael Juma Congratulations Vahid! > > On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > > committer and > > we are > > pleased to announce that he has accepted! > >

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Srinivas Reddy
Congratulation Vahid!!! > On 16 Jan 2019, at 9:58 AM, Manikumar wrote: > > Congrats, Vahid! > > On Wed 16 Jan, 2019, 6:53 AM Ismael Juma >> Congratulations Vahid! >> >> On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson > >>> Hi All, >>> >>> The PMC for Apache Kafka has invited Vahid Hashemian

Re: [VOTE] KIP-258: Allow to Store Record Timestamps in RocksDB

2019-01-15 Thread Bill Bejeck
Thanks for the KIP Matthias. +1 -Bill On Tue, Jan 15, 2019 at 7:33 PM Matthias J. Sax wrote: > Hi, > > I would like to start the vote for KIP-258: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-258%3A+Allow+to+Store+Record+Timestamps+in+RocksDB > > The KIP adds new stores that all

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Gwen Shapira
Congrats, Vahid. Thank you for all your contribution! On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contributions to the K

Re: [VOTE] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Gwen Shapira
+1 Thank you! On Tue, Jan 15, 2019, 3:38 PM Rajini Sivaram Hi all, > > I would like to start vote on KIP-402 to improve fairness in channel > processing in SocketServer to protect brokers from connection storms and > limit the total number of connections in brokers to avoid OOM. The KIP is > her

imamba_kafka request permission to Create KIP

2019-01-15 Thread Imamba Sun
Wiki ID: imamba_kafka Full Name: Fangbin Sun thanks!

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Alex D
Congrats, Vahid! On Wed, 16 Jan 2019, 05:54 Gwen Shapira Congrats, Vahid. Thank you for all your contribution! > > On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > > committer and > > we are > > pleased to annou

imamba_kafka request permission to Create KIP

2019-01-15 Thread Imamba Sun
Wiki ID: imamba_kafka thanks!

Re: [VOTE] KIP-258: Allow to Store Record Timestamps in RocksDB

2019-01-15 Thread Patrik Kleindl
+1 (non-binding) Thanks too Best regards Patrik > Am 16.01.2019 um 03:30 schrieb Bill Bejeck : > > Thanks for the KIP Matthias. > > +1 > > -Bill > > On Tue, Jan 15, 2019 at 7:33 PM Matthias J. Sax > wrote: > >> Hi, >> >> I would like to start the vote for KIP-258: >> >> >> https://cwiki.

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

2019-01-15 Thread Jan Filipiak
On 15.01.2019 13:27, Rajini Sivaram wrote: > Hi Jan, > > If the queue of one Processor is full, we move to the next Processor > immediately without blocking. So as long as the queue of any Processor is > not full, we accept the connection immediately. If the queue of all > Processors are full, we a

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Dong Lin
Congratulations Vahid! On Tue, Jan 15, 2019 at 2:45 PM Jason Gustafson wrote: > Hi All, > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > committer and > we are > pleased to announce that he has accepted! > > Vahid has made numerous contributions to the Kafka community over

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Suman B N
Congrats Vahid! On Wed, Jan 16, 2019 at 12:02 PM Dong Lin wrote: > Congratulations Vahid! > > On Tue, Jan 15, 2019 at 2:45 PM Jason Gustafson > wrote: > > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > > committer and > > we are > > pleased to announce tha

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Dongjin Lee
Congratulations, Vahid!! On Wed, Jan 16, 2019 at 3:32 PM Dong Lin wrote: > Congratulations Vahid! > > On Tue, Jan 15, 2019 at 2:45 PM Jason Gustafson > wrote: > > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > > committer and > > we are > > pleased to anno

Re: imamba_kafka request permission to Create KIP

2019-01-15 Thread Matthias J. Sax
Done. On 1/15/19 7:13 PM, Imamba Sun wrote: > Wiki ID: imamba_kafka > Full Name: Fangbin Sun > thanks! > > > > > > signature.asc Description: OpenPGP digital signature

Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL

2019-01-15 Thread Matthias J. Sax
While I understand that it should be possible to specify store name and processor name independent from each other, it's still unclear to me, why we cannot use the `Materialized` parameter to specify the processor name: > // only set the node name > #count(Named.as("processorName")); > > // only

[DISCUSS] KIP-417: Allow JmxTool to connect to a secured RMI port

2019-01-15 Thread Imamba Sun
Hi All: I submitted a relatively simple KIP about improving the Kafka protocol and the JmxTool to support to connect to a secured RMI port. Any advise or guidance would be greatly appreciated, I would be happy to receive some opinions about this. It is necessary to enable security when monit