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
creati
M wan...@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
>
>
>
>
> FAILUR
~/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 pr
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
> 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
wrote:
> hi, I would like to subscribe
>
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. t
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.
> Again the big question
ew Date(); console.log('\nDone test');
>>
>
>
>>
> > var mps = parseInt(target/((stop-start)/1000));
>>
>
>
>>
> > console.log('Received at ' + mp
;
>
> >
>
> >>
>
> > > producer.on('ready', function () { var message = 'Hello World';
>
> >>
>
> >
>
> >
>
> >>
>
> > > for (var i=0; i
> >>
>
> >
>
> >
>
> >>
>
> > > topic, partition: p, messages: message, attributes: a } ], function
>
> >>
>
var options = { autoCommit: false, fetchMaxWaitMs:
>>
>
>
>>
> > 1000 }; var consumer = new Consumer(client, topics, options); var
>>
>
>
>>
> > offset = new Offset(client); var start; var received = 0; var
>>
>
>
>>
> >
('optimist').argv; var topic =
>>
>
>
>>
> > argv.topic || 'kafka_test'; var client = new
>>
>
>
>>
> > Client('172.31.21.175:2181'); var topics = [ {topic: topic,
>>
>
>
tion (err) { console.log('error', err); });
>
> Not using Mixmax yet?
>
>
>
>
>
>
>
> On Wed, Sep 14, 2016 11:58 PM, Ali Akhtar ali.rac...@gmail.com
> wrote:
> It sounds like a
top = new Date(); console.log('\nDone test');
>
> > var mps = parseInt(target/((stop-start)/1000));
>
> > console.log('Received at ' + mps + ' msgs/sec'); process.exit();
>
> > } else if (received % hash === 0){
>
> > process.stdou
> console.log('Received at ' + mps + ' msgs/sec'); process.exit();
> } else if (received % hash === 0){
> process.stdout.write(received + '\n'); } });
> consumer.on('error', function (err) { console.log('error', err); });
>
> N
nt(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) { console.log(
); process.exit();
> } else if (received % hash === 0){
> process.stdout.write(received + '\n');}});
> consumer.on('error', function (err) { console.log('error', err);});
>
> Not using Mixmax yet?
>
>
>
>
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 Thu, Sep 15, 2016 at 11:51 AM, kant kodali wrote:
Hi,
I have the following setup.
Single Kafka broker and Zookeeper on Machine 1single Kafka produce
It sounds like a network issue. Where are the 3 servers located / hosted?
On Thu, Sep 15, 2016 at 11:51 AM, kant kodali wrote:
> Hi,
> I have the following setup.
> Single Kafka broker and Zookeeper on Machine 1single Kafka producer on
> Machine 2
> Single Kafka Consumer on Mac
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
The issue doesn't seem to point to anything. Do you mind sending it in a
pastebin?
On Thu, Oct 10, 2013 at 9:54 PM, Jiang Jacky wrote:
> 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 pa
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
share with me?
Thanks a lot.
2013/10/7 Jun Rao
> 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 wrote:
>
> > Hi, I tried to setup the host.name 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 wrote:
>
> > Hi, I tried to setup the host.name in servier.properties, it doesn't
> work.
> > I b
did anyone experience same issue? can you share with me?
Thanks a lot.
2013/10/7 Jun Rao
> 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 wrote:
>
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 wrote:
> Hi, I tried to setup the host.name in servier.properties, it doesn't work.
> I believe it is the network security issue. However,
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 wrote:
> Hi, I tried to setup the host.name in servier.properties, it doesn't work.
> I believe it is the netwo
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
ac
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 wrote:
> It is very weird, I have a kafka cluster in EC2, There is no any problem
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 iss
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" wrote:
> i am using kafka .i need to create one message on producer side and send to
> multiple consumer...?
>
37 matches
Mail list logo
