Re: [ANNOUNCE] New committer: Ron Dagostino

2022-12-16 Thread Raymond Ng
Congratulations, Ron! /Ray On Fri, Dec 16, 2022 at 3:04 PM Ron Dagostino wrote: > Thanks again, everyone! > > Ron > > > On Dec 16, 2022, at 12:37 PM, Bill Bejeck wrote: > > > > Congratulations, Ron! > > > > -Bill > > > >> On Fri, Dec 16, 2022 at 12:33 PM Matthias J. Sax > wrote: > >> > >> Co

Re: [ANNOUNCE] New Kafka PMC Member: Randall Hauch

2021-04-16 Thread Raymond Ng
Congrats Randall! On Fri, Apr 16, 2021 at 4:45 PM Matthias J. Sax wrote: > Hi, > > It's my pleasure to announce that Randall Hauch in now a member of the > Kafka PMC. > > Randall has been a Kafka committer since Feb 2019. He has remained > active in the community since becoming a committer. > >

Re: [ANNOUNCE] New committer: David Jacot

2020-10-16 Thread Raymond Ng
Congrats David! Cheers, Ray On Fri, Oct 16, 2020 at 10:08 AM Rajini Sivaram wrote: > Congratulations, David! > > Regards, > > Rajini > > On Fri, Oct 16, 2020 at 5:45 PM Matthias J. Sax wrote: > > > Congrats! > > > > On 10/16/20 9:25 AM, Tom Bentley wrote: > > > Congratulations David! > > > > >

Re: Can anyone help me to send messages in their original order?

2018-05-26 Thread Raymond Xie
. ** *Sincerely yours,* *Raymond* On Sat, May 26, 2018 at 4:26 PM, Hans Jespersen wrote: > There are two concepts in Kafka that are not always familiar to people who > have used other pub/sub systems. > > 1) partitions: > > Kafka topics are partitioned which means a single topic is shard

Re: Can anyone help me to send messages in their original order?

2018-05-26 Thread Raymond Xie
you create a topic with one partition they will be in order. > > Alternatively if you publish with the same key for every message they will > be in the same order even if your topic has more than 1 partition. > > Either way above will work for Kafka. > > -hans > > > On May

Can anyone help me to send messages in their original order?

2018-05-25 Thread Raymond Xie
also want to know what is the best practice to process large volume of data through kafka? There should be better way other than console command. Thank you very much. ** *Sincerely yours,* *Raymond*

Kafka using existing certificate authority.

2018-04-17 Thread Shawn Raymond
I am trying to set up apache kafka using an existing certificate authority, and I cannot find any documentation related to this option. also is there an ssl setting to use a different type of keystore then jks? Please respond as soon as anyone can. Thank you. -- Shawn P. Raymond I RHCSA

Question Related to Zookeeper and kafka java error message.

2018-02-09 Thread Raymond, Shawn P CTR USARMY NETCOM (US)
(ClientCnxn.java:1141) does anyone have a clue how to fix these errors, I am running on RHEL 7.4. the strange thing is replication is working and topics are being listed. Any assistance would be appreciated. thank you. V/R Shawn P. Raymond I RHCSA, CISSP, GSEC, GISP, SCSA, MCSA, MCNPS

Re: No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException

2017-02-25 Thread Raymond Xie
Thank you very much Marco, I am a beginner in this area, is it possible for you to show me what you think the right script should be to get it executed in terminal? ** *Sincerely yours,* *Raymond* On Sat, Feb 25, 2017 at 6:00 PM, Marco Mistroni

Re: No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException

2017-02-25 Thread Raymond Xie
mbly-*.jar \ examples/src/main/python/streaming/kafka_wordcount.py \ localhost:2181 test` """ Can anyone give any thought on how to find out? Thank you very much in advance. *----* *Sincerely yours,* *Raymond* On Sat, Feb 25, 2017 at 5:27

Re: No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException

2017-02-25 Thread Raymond Xie
Thank you, it is still not working: [image: Inline image 1] By the way, here is the original source: https://github.com/apache/spark/blob/master/examples/src/main/python/streaming/kafka_wordcount.py ** *Sincerely yours,* *Raymond* On Sat, Feb

No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException

2017-02-25 Thread Raymond Xie
/usr/hdp/2.5.0.0-1245/kafka/libs/kafka-streams-0.10.0.2.5.0.0-1245.jar ** *Sincerely yours,* *Raymond*

Need guidance to create a pipeline

2017-02-20 Thread Raymond Xie
.10, the following works for me: ./kafka-console-producer.sh --broker-list sandbox.hortonworks.com:6667 --topic kafka-topic1 Can anyone help? Thank you very much. ** *Sincerely yours,* *Raymond*

question about console producer behavior

2014-11-03 Thread raymond
Hi It appears to me that, when I have opened a console producer, it will not notice the topic’s partition change? say I have a topic with 3 partitions. And I opened a console producer to produce data with key, then it will distribute data into 3 partitions. Then , I keep this producer open, an

RE: which repo for kafka_2.10 ?

2013-11-08 Thread Liu, Raymond
Thanks. Good to know that it will come to formal 0.8.0 release soon. I am really looking for the public maven repo for porting sparks on to it instead of running a local version ;) probably I can do with a beta1 one firstly. Best Regards, Raymond Liu -Original Message- From: Joe Stein

which repo for kafka_2.10 ?

2013-11-07 Thread Liu, Raymond
If I want to use kafka_2.10 0.8.0-beta1, which repo I should go to? Seems apache repo don't have it. While there are com.sksamuel.kafka and com.twitter.tormenta-kafka_2.10 Which one should I go to or neither? Best Regards, Raymond Liu