I like the way you written it without fullstop…. Lol
On Mon, 28 Nov 2022 at 8:48 PM, Schehrzade
wrote:
> I like the author Kafka and I was so impressed someone had written code or
> whatever I don’t know because I’m not from this country and I don’t know
> stuff about science and all but it was
I like the author Kafka and I was so impressed someone had written code or
whatever I don’t know because I’m not from this country and I don’t know
stuff about science and all but it was really cool and even the logo and
font and then I started to watch your video and the idea was so
...@emrubik.com
wrote:
> sorry , the picture is not displayed
>
>
>
> *From:* wan...@emrubik.com
> *Date:* 2021-11-17 16:10
> *To:* users
> *Subject:* Hi Team,
> Hi Team,
>
> I want obtain consumer group information through the Kafka JAVA API ,As
> shown in figure
>
&g
sorry , the picture is not displayed
From: wan...@emrubik.com
Date: 2021-11-17 16:10
To: users
Subject: Hi Team,
Hi Team,
I want obtain consumer group information through the Kafka JAVA API ,As shown
in figure
Properties properties = new Properties();
properties.put
Hi Team,
I want obtain consumer group information through the Kafka JAVA API ,As shown
in figure
Properties properties = new Properties();
properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG,
"10.127.16.2:9092");
try {
String groupId =
It should work with 6.6[1], or use the included gradlew script to bootstrap
and use the right gradle version.
Kind regards,
Tom
[1]:
https://github.com/apache/kafka/blob/2.7.0/gradle/wrapper/gradle-wrapper.properties
On Wed, Jan 27, 2021 at 9:52 AM felixzh wrote:
> Hi,
> Gradle
Hi,
Gradle 5.6.4
At 2021-01-27 17:40:17, "Liam Clarke-Hutchinson"
wrote:
>Hi,
>
>What version of Gradle?
>
>Cheers,
>
>Liam
>
>On Wed, 27 Jan. 2021, 10:35 pm felixzh, wrote:
>
>> ~/Downloads/kafka-2.7.0# gradle clean
>>
>
Hi,
What version of Gradle?
Cheers,
Liam
On Wed, 27 Jan. 2021, 10:35 pm felixzh, wrote:
> ~/Downloads/kafka-2.7.0# gradle clean
>
>
>
>
> > Configure project :
>
> Building project 'core' with Scala version 2.13.3
>
>
>
>
> FAILURE: Build f
~/Downloads/kafka-2.7.0# gradle clean
> Configure project :
Building project 'core' with Scala version 2.13.3
FAILURE: Build failed with an exception.
* Where:
Build file '/root/Downloads/kafka-2.7.0/build.gradle' line: 471
* What went wrong:
A problem occurred evaluating root
cc'ed Daniele :)
On 9/21/17 1:59 PM, Ted Yu wrote:
> Please follow instructions on http://kafka.apache.org/contact
>
> On Thu, Sep 21, 2017 at 1:30 PM, Daniele Ascione <ascion...@gmail.com>
> wrote:
>
>> hi, I would like to subscribe
>>
>
signature.asc
Description: OpenPGP digital signature
Please follow instructions on http://kafka.apache.org/contact
On Thu, Sep 21, 2017 at 1:30 PM, Daniele Ascione <ascion...@gmail.com>
wrote:
> hi, I would like to subscribe
>
hi,man
i have an problem when using kafka,
when i set acl in zookeeper on /, then i try to restart kafka, but it
doesn't work:
org.I0Itec.zkclient.exception.ZkException:
org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth
how to settle this problem. thanks
I'd post to the mailing list again with a new subject and ask that.
On Thu, Sep 15, 2016 at 1:52 PM, kant kodali wrote:
> I used node.js client libraries for all three and yes I want to make sure
> I am
> comparing apples to apples so I make it as equivalent as possible.
>
;
>>
> > console.log('Received at ' + mps + ' msgs/sec'); process.exit();
>>
>
>
>>
> > } else if (received % hash === 0){
>>
>
>
>>
> > process.stdout.write(received + '\n'); } });
>>
>
>
>>
> > consumer.on('error', funct
partition: p, messages: message, attributes: a } ], function
>
> >>
>
> >
>
> >
>
> >>
>
> > > (err, result) { console.log(err || result);
>
> >>
>
> >
>
> >
>
> >>
>
> > > //process.exit(); }); }
gt; partition: 0} ]; var options = { autoCommit: false, fetchMaxWaitMs:
>>
>
>
>>
> > 1000 }; var consumer = new Consumer(client, topics, options); var
>>
>
>
>>
> > offset = new Offset(client); var start; var received = 0; var
>>
>
>
>>
> > target = 20
utoCommit: false, fetchMaxWaitMs:
>>
>
>
>>
> > 1000 }; var consumer = new Consumer(client, topics, options); var
>>
>
>
>>
> > offset = new Offset(client); var start; var received = 0; var
>>
>
>
>>
>
>
>
>
>
>
>
> On Wed, Sep 14, 2016 11:58 PM, Ali Akhtar ali.rac...@gmail.com
> wrote:
> It sounds like a network issue. Where are the 3 servers located / hosted?
>
>
>
>
> On
> var mps = parseInt(target/((stop-start)/1000));
>
> > console.log('Received at ' + mps + ' msgs/sec'); process.exit();
>
> > } else if (received % hash === 0){
>
> > process.stdout.write(received + '\n'); } });
>
> > consumer.on('error', function (err) { con
; wrote:
> It sounds like a network issue. Where are the 3 servers located / hosted?
>
>
>
>
> On Thu, Sep 15, 2016 at 11:51 AM, kant kodali <kanth...@gmail.com> wrote:
>
>
>
>
> Hi,
>>
>
> I have the following setup.
>>
, Ali Akhtar ali.rac...@gmail.com
> wrote:
> It sounds like a network issue. Where are the 3 servers located / hosted?
>
>
>
>
> On Thu, Sep 15, 2016 at 11:51 AM, kant kodali <kanth...@gmail.com> wrote:
>
>
>
>
> Hi,
>>
>
> I have t
It sounds like a network issue. Where are the 3 servers located / hosted?
>
>
>
>
> On Thu, Sep 15, 2016 at 11:51 AM, kant kodali <kanth...@gmail.com> wrote:
>
>
>
>
> Hi,
>>
>
> I have the following setup.
>>
>
> Single Kafka broker and Zooke
tar ali.rac...@gmail.com
wrote:
It sounds like a network issue. Where are the 3 servers located / hosted?
On Thu, Sep 15, 2016 at 11:51 AM, kant kodali <kanth...@gmail.com> wrote:
Hi,
I have the following setup.
Single Kafka broker and Zookeeper on Machine 1single Kafka
It sounds like a network issue. Where are the 3 servers located / hosted?
On Thu, Sep 15, 2016 at 11:51 AM, kant kodali <kanth...@gmail.com> wrote:
> Hi,
> I have the following setup.
> Single Kafka broker and Zookeeper on Machine 1single Kafka producer on
> Machine 2
>
Hi,
I have the following setup.
Single Kafka broker and Zookeeper on Machine 1single Kafka producer on Machine 2
Single Kafka Consumer on Machine 3
When a producer client sends a message to the Kafka broker by pointing at the
Zookeeper Server the consumer doesn't seem to get the message right
did anyone experience same issue? can you share with me?
Thanks a lot.
2013/10/7 Jun Rao jun...@gmail.com
Kafka port is documented in
http://kafka.apache.org/documentation.html#brokerconfigs
Thanks,
Jun
On Sat, Oct 5, 2013 at 12:05 PM, Jiang Jacky jiang0...@gmail.com wrote:
Hi, I
Kafka port is documented in
http://kafka.apache.org/documentation.html#brokerconfigs
Thanks,
Jun
On Sat, Oct 5, 2013 at 12:05 PM, Jiang Jacky jiang0...@gmail.com wrote:
Hi, I tried to setup the host.name in servier.properties, it doesn't
work.
I believe it is the network security issue
with me?
Thanks a lot.
2013/10/7 Jun Rao jun...@gmail.com
Kafka port is documented in
http://kafka.apache.org/documentation.html#brokerconfigs
Thanks,
Jun
On Sat, Oct 5, 2013 at 12:05 PM, Jiang Jacky jiang0...@gmail.com wrote:
Hi, I tried to setup the host.name in servier.properties
Hi, Thanks Joe
I have disabled the firewall, but I did not tried that again, I changed
another way by using Netty sending the socket package to kafka server, then
it will produce in the local. But recently I suddenly ran into below issue,
can you have a look?
https://mail.google.com/mail/ca/u/0
Kafka port is documented in
http://kafka.apache.org/documentation.html#brokerconfigs
Thanks,
Jun
On Sat, Oct 5, 2013 at 12:05 PM, Jiang Jacky jiang0...@gmail.com wrote:
Hi, I tried to setup the host.name in servier.properties, it doesn't work.
I believe it is the network security issue
Hi, Can anyone give me an example? Or the props settings ? I am using the
latest version of Kafka.
Appreciate!
Sent from my iPhone
On 2013-10-05, at 15:05, Jiang Jacky jiang0...@gmail.com wrote:
Hi, I tried to setup the host.name in servier.properties, it doesn't work.
I believe
Hello Jacky,
Have you read this FAQ:
https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-OnEC2%2Cwhycan%27tmyhighlevelconsumersconnecttothebrokers%3F
Guozhang
On Fri, Oct 4, 2013 at 10:41 PM, Jiang Jacky jiang0...@gmail.com wrote:
It is very weird, I have a kafka cluster in EC2, There
Hi, I tried to setup the host.name in servier.properties, it doesn't work.
I believe it is the network security issue. However, I create a new
instance in the same security group without kafka, zookeeper, it does work,
it can still produce to kafka server. but when I change to another ec2
account
It is very weird, I have a kafka cluster in EC2, There is no any problem to
produce message from one of node by same producer. But when I move the
producer to my local machine at home, then it gives me the below error:
Failed to send messages after 3 tries.
Can anyone tell me how do I fix this
You can do that using Kafka. Please read the design details here -
http://kafka.apache.org/07/design.html
Thanks,
Neha
On May 20, 2013 6:57 AM, satya prakash satyacusa...@gmail.com wrote:
i am using kafka .i need to create one message on producer side and send to
multiple
35 matches
Mail list logo