Follow instruction from the webpage: https://kafka.apache.org/contact
On 6/4/24 9:01 AM, outof2...@sina.com wrote:
I want to subscribe
I want to subscribe
subscribe
o
we can do the blocking ourselves until we get the completion signal.
best
Sebastian
[1] https://pastebin.com/kmE0FJMy
On Tue, Jan 25, 2022 at 8:27 AM Luke Chen wrote:
>
> Yes, there is no such "synchronous subscribe" method in Kafka.
> Consumer group will start to work after
ogic
> is blocking and I find the following behavior unexpected...
>
> var con = ... // get consumer instance
> con.subscribe(Set.of(SOME_TOPIC));
> var records = con.poll(Duration.ZERO)
>
> The poll will return an empty records array, even though there *IS*
> data in
Yes, there is no such "synchronous subscribe" method in Kafka.
Consumer group will start to work after `poll` is called.
Inside Kafka, there are util methods like `awaitAssignment` or
`awaitRebalance` to wait for the initialization completed for tests, which
is checking with `poll`
You
ds array, even though there *IS*
> data in said topic. Even when I register a `ConsumerRebalanceListener`
> in the subscribe call, I won't ever see any assignment of
> `TopicPartition` to the consumer, not even a delayed one.
>
> On the other hand, when I change the code to
>
>
unexpected...
var con = ... // get consumer instance
con.subscribe(Set.of(SOME_TOPIC));
var records = con.poll(Duration.ZERO)
The poll will return an empty records array, even though there *IS*
data in said topic. Even when I register a `ConsumerRebalanceListener`
in the subscribe cal
Hello Bhavik,
You need to send to a separate mailing list to subscribe:
https://kafka.apache.org/contact
On Thu, Sep 16, 2021 at 8:48 AM Bhavik Ambani
wrote:
> Subscribe for mailing list
>
--
-- Guozhang
I have already subscribed and there is a notification! Please check!
чт, 16 сент. 2021 в 18:49 Bhavik Ambani
написал(-а): Subscribe for mailing list
Subscribe for mailing list
Hi,
You should send an email to dev-subscr...@kafka.apache.org to subscribe to
Kafka dev mailing list.
Luke
Thanks.
On Thu, Dec 3, 2020 at 12:40 AM 阿满 <6065...@qq.com> wrote:
> Subscribe to Kafka dev mailing list
Subscribe to Kafka dev mailing list
If you want to subscribe, please follow the instructions from the web
page: https://kafka.apache.org/contact
-Matthias
On 10/19/20 6:32 PM, Peng Lei wrote:
>
>
Hello All,
Just trying to understand if the subscribe API broken somehow?
Reference:
https://stackoverflow.com/questions/42707131/kafka-consumer-api-failed-to-subscribe-to-topic
I am actually facing the same issue where call to subscribe() and followed by
poll() within an infinite while look
Hi Roc,
The 'signature' is not related to the subscription.
Again, if you want to subscribe to the mailing list, please follow the
instructions from the web page: https://kafka.apache.org/contact.
<https://kafka.apache.org/contact>
That is, to send an email to users-subscr...@
Ok.I have a little question about your reply. Is the attachment
'signature' used as the voucher for subscribing to the email?Thank
you.Best Roc.
At 2020-06-07 04:26:47, "Matthias J. Sax" wrote:
>Roc,
>
>if you want to subscribe to the mailing list, please follow
Roc,
if you want to subscribe to the mailing list, please follow the
instruction from the web page: https://kafka.apache.org/contact
-Matthias
On 6/6/20 9:32 AM, Roc Marshal wrote:
> flin...@126.com
>
signature.asc
Description: OpenPGP digital signature
flin...@126.com
Hi there! To subscribe to the list, you have to email a different address:
users-subscr...@kafka.apache.org. (see https://kafka.apache.org/contact.html).
This also applies to the message you sent to dev (should have been
dev-subscr...@kafka.apache.org).
Thanks for joining the conversation
subscribe kafka user mail
25 PM ASHOK MACHERLA wrote:
> Hi Teammates
>
> Can anyone guide me to un-subscribe from Kafka user group.
>
>
> Sent from Outlook<http://aka.ms/weboutlook>
>
I think you should send an email to users-unsubscr...@kafka.apache.org -
that should get you unsubscribed.
Jakub
On Tue, Jul 30, 2019 at 3:25 PM ASHOK MACHERLA wrote:
> Hi Teammates
>
> Can anyone guide me to un-subscribe from Kafka user group.
>
>
> Sent from Outlook<http://aka.ms/weboutlook>
>
Hi Teammates
Can anyone guide me to un-subscribe from Kafka user group.
Sent from Outlook<http://aka.ms/weboutlook>
Hi,
When our consumer poll messages from a topic every partition has very
large delay,we found that some partitions decrease delay fast but others
are even still increase.
I think the reason is every consumer subscribes sevral partitions and
broker will always response messages with the same p
David,
If the consumers never commit() or subscribe(), I don't think the group.id
is relevant.
Ryanne
On Wed, Oct 17, 2018 at 10:04 AM David Baraff wrote:
> I’m using Kafka for what I think is a somewhat non-standard purpose. We
> have multiple producers which send messages to a
sumers DO NOT commit offsets ever
+ new consumers set the offset to the “latest available” when they start
+ consumers don’t subscribe: they assign themselves to partition 0 of
the topic
This works fine: each consumer appears to get a copy of all the (new) messages
that come in,
9:37 PM Bobai Kato wrote:
> Hi y’all,
>
> I’m pretty new to Kafka and wondering how many consumers I can have on a
> topic.
>
> Can I have 500+ users subscribe to particular topic ?
>
> — Bobai (https://www.bobaikato.io/)
>
>
--
*Suman*
*OlaCabs*
Hi y’all,
I’m pretty new to Kafka and wondering how many consumers I can have on a topic.
Can I have 500+ users subscribe to particular topic ?
— Bobai (https://www.bobaikato.io/)
Please see https://kafka.apache.org/contact
On Fri, Jun 29, 2018 at 10:54 AM, chinchu chinchu
wrote:
>
>
To subscribe, please follow instructions here:
https://kafka.apache.org/contact
On 5/24/18 8:16 PM, wrote:
> subscribe mail list
>
signature.asc
Description: OpenPGP digital signature
subscribe mail list
t might be
the port. Perhaps the test case uses a SSL backed port?
-Jaikiran
On 13/05/18 1:46 PM, James Yu wrote:
Hi,
Does anyone publish or subscribe kafka topic in TestNG?
I try to publish and subscribe kafka topic in my TestNG test case, and I
always get the following exception:
2018-05-
Hi,
Does anyone publish or subscribe kafka topic in TestNG?
I try to publish and subscribe kafka topic in my TestNG test case, and I
always get the following exception:
2018-05-13 15:33:58.540 WARN
o.a.kafka.common.network.Selector.pollSelectionKeys[531] - [Producer
clientId=producer-1
See https://kafka.apache.org/contact
Original message From: "vinly.zhao"
Date: 4/9/18 5:21 AM (GMT-08:00) To: users@kafka.apache.org Subject:
subscribe kafka user group
Thanks,
*Vincent Zhao*
Thanks,
*Vincent Zhao*
> Sometimes it seems to receive messages from all partitions (0, 1, 2).
> At other times, it seems to start up only listening to just one
> partition.
Eh, never mind. Looks like pilot error. I accidentally had a stalled
client still running. ("Stalled", as in had been doing something
useful, but w
, use of group_id means some partition assignment
strategy comes into play. I'm also subscribing to a list of topics
using the subscribe method. Setup looks like this:
consumer = kafka.KafkaConsumer(bootstrap_servers="mybroker:9092",
group_id="mygroup")
consumer.subsc
It's self-service:
https://kafka.apache.org/contact
-Matthias
On 10/17/17 11:51 AM, Nikhil Deore wrote:
> Hi,
>
> I want to learn and contribute to this project,
> Please subscribe me in.
>
> Thanks,
> Nikhil
>
signature.asc
Description: OpenPGP digital signature
Hello Nikihil,
It is a self-service.
Guozhang
On Tue, Oct 17, 2017 at 10:36 AM, Nikhil Deore
wrote:
> Thank you,
> Nikhil
>
--
-- Guozhang
Hi,
I want to learn and contribute to this project,
Please subscribe me in.
Thanks,
Nikhil
Hi,
I want to learn and contribute to this project,
Please subscribe me in.
Thanks,
Nikhil
Thank you,
Nikhil
Hi,
I'm not entirely certain this is the right place to ask, but I have
questions about the functioning of Apache Kafka to implement a
publish/subscribe messaging system. I am investigating Kafka to see if it
fits the needs of the company I work for, and I have quite a few questions
I can
It will not interfere. And this is independent of manual partition
assignment or topic subscription. If you have different consumer
group-ids it's independent of each other.
-Matthias
On 7/12/17 11:21 PM, venkata sastry akella wrote:
> Hi
> Can I have a one consumer group with automatic subcrip
Hi
Can I have a one consumer group with automatic subcription and one group
with manual assignment of partitions. To explain the scenario more, have
a topic1 and several consumer processes are using group1 and each of the
consumers in the groups got partitions assigned automatically by kafka.
For
Arun ,
send e-mail to users-subscr...@kafka.apache.org
Thanks,
Prahalad
On Wed, Apr 19, 2017 at 8:24 PM, Arunkumar
wrote:
>
> Hi There
> I would like to subscribe to this mailing list and know more about kafka.
> Please add me to the list. Thanks in advance
>
> Thanks
>
Hi There
I would like to subscribe to this mailing list and know more about kafka.
Please add me to the list. Thanks in advance
Thanks
Arunkumar Pichaimuthu, PMP
It's more helpful to cc'ed people that are not subscribed yet if you
answer :)
-Matthias
On 4/4/17 11:39 PM, Shuai Lin wrote:
> To subscribe you should send a message to users-subscr...@kafka.apache.org.
> Please follow the instructions on https://kafka.apache.org/contact .
&g
To subscribe you should send a message to users-subscr...@kafka.apache.org.
Please follow the instructions on https://kafka.apache.org/contact .
On Wed, Apr 5, 2017 at 2:36 PM, Vidya Priyadarshni Narayan <
vidya.nara...@go-jek.com> wrote:
> --
>
> Thanks
> nVidia
>
--
Thanks
nVidia
It's self service.
See: http://kafka.apache.org/contact
-Matthias
On 3/1/17 8:48 AM, Mina Aslani wrote:
> Hi,
>
> I would like to subscribe to user mailing list.
>
> Best regards,
> Mina
>
signature.asc
Description: OpenPGP digital signature
Hi,
I would like to subscribe to user mailing list.
Best regards,
Mina
Teal, Nicholas [mailto:nicholas.t...@va.gov]
Sent: Friday, January 13, 2017 8:46 AM
To: users@kafka.apache.org
Subject: First time implimention of publish and subscribe
I am being tasked to implement a publish and subscribe database system for
patient data and am looking at apache to perform this
I am being tasked to implement a publish and subscribe database system for
patient data and am looking at apache to perform this but am unclear as to
which product would be best to use. It looks like apache kafka but I have
found other apache products that provide this function as well. Is
Subscribe.
You need to send an email to users-subscr...@kafka.apache.org
See https://kafka.apache.org/contact.html
-Matthias
On 07/06/2016 10:26 PM, Manoj Chaudhary wrote:
> Thanks
> Manoj
>
signature.asc
Description: OpenPGP digital signature
Thanks
Manoj
It depends. If auto.topic.create.enable is true, a topic will be created.
If its false, you will get some kind of topic doesn't exist exception.
Gwen
On Thu, Apr 7, 2016 at 11:49 AM, Shravan Ambati
wrote:
> Hi,
>
> I could not find answer to this in the documentation.
> In Kafka 0.9.X, what hap
Hi,
I could not find answer to this in the documentation.
In Kafka 0.9.X, what happens when the consumer calls consumer.subscribe for a
non existant topic?
Thanks
Shravan
subscribe
Please add me to this mailing list.
Thanks
Amit Kumar
kafka.apache.org/contact.html
>
>On Tue, Mar 15, 2016 at 11:48 AM, Punyavathi Ambur Krishnamurthy <
>akpunyava...@athenahealth.com> wrote:
>
>> Hi,
>>
>> I would like to subscribe to this list to learn and implement Kafka.
>>
>> Thanks,
>>
Your best bet is to send a mail to subscr...@kafka.apache.org as outlined
in the mailing list page http://kafka.apache.org/contact.html
On Tue, Mar 15, 2016 at 11:48 AM, Punyavathi Ambur Krishnamurthy <
akpunyava...@athenahealth.com> wrote:
> Hi,
>
> I would like to subscribe
Hi,
I would like to subscribe to this list to learn and implement Kafka.
Thanks,
Punya
Guozhang
Thanks for the explanation !!
Mansi.
Sent from my iPhone
> On Mar 5, 2016, at 3:38 PM, Guozhang Wang wrote:
>
> Guozhang
Hi Mansi,
1) subscribe is a lazy call: only the subsequent poll() will do the leg
work of talking to broker, registering the subscription, getting assigned
partitions and issuing fetch requests to the partition leaders.
2) currently the timeout value for poll() does not count for the time
Hi,
I had a question around expected behavior / API expectations.
Is subscribe a lazy call? What I mean by that is if I subscribe to a topic and
then call poll(0), then is this first poll guaranteed to never return data?
Will the data pre-fetch not start as soon as subscribe is called? Is
Oops! So sorry about that...
On Tue, Jan 26, 2016 at 8:25 PM, Henrik Lundahl
wrote:
> Hi
>
> Perhaps someone already told you, but you should send to
> users-h...@kafka.apache.org instead to subscribe.
>
>
> BR
>
> --
> Henrik
>
>
>
> On Sun, Jan 24, 2016 at 8:48 AM, Richard He
> wrote:
>
>>
>>
>
Hi
Perhaps someone already told you, but you should send to
users-h...@kafka.apache.org instead to subscribe.
BR
--
Henrik
On Sun, Jan 24, 2016 at 8:48 AM, Richard He wrote:
>
>
that. The commit API
> > will not work for a consumer using manual assignment if its groupId is
> > shared with another consumer using automatic assignment (with
> subscribe()).
> > When a consumer group is active, Kafka only allows commits from members
> of
> > th
its groupId is
> shared with another consumer using automatic assignment (with subscribe()).
> When a consumer group is active, Kafka only allows commits from members of
> that group.
>
> -Jason
>
> On Fri, Nov 20, 2015 at 3:41 PM, Jason Gustafson
> wrote:
>
> > Hey S
I suppose I should have added one qualification to that. The commit API
will not work for a consumer using manual assignment if its groupId is
shared with another consumer using automatic assignment (with subscribe()).
When a consumer group is active, Kafka only allows commits from members of
that
Hey Siyuan,
The commit API should work the same regardless whether subscribe() or
assign() was used. Does this not appear to be working?
Thanks,
Jason
On Wed, Nov 18, 2015 at 4:40 PM, hsy...@gmail.com wrote:
> In the new API, the explicit commit offset method call only works for
> sub
In the new API, the explicit commit offset method call only works for
subscribe consumer, not the assign consumer, correct?
Best,
Siyuan
Hey Kashif, to subscribe, send a message to users-subscr...@kafka.apache.org
.
-Jason
On Tue, Jun 30, 2015 at 1:16 AM, Kashif Hussain wrote:
> Hi,
> I want to subscribe Kafka users mailing list.
>
> Regards,
> Kashif
>
Hi,
I want to subscribe Kafka users mailing list.
Regards,
Kashif
Hello Jin,
You can subscribe following these instructions:
http://kafka.apache.org/contact.html
Guozhang
On Tue, Jun 16, 2015 at 11:31 AM, Jin Wang wrote:
>
>
--
-- Guozhang
subscribe
thank you
istrative commands for the users list ---
>
> I can handle administrative requests automatically. Please
> do not send them to the list address! Instead, send
> your message to the correct command address:
>
> To subscribe to the list, send a message to:
>
>
> To remove
Please subscribe for the group
Ajay
istrative commands for the users list ---
>
> I can handle administrative requests automatically. Please
> do not send them to the list address! Instead, send
> your message to the correct command address:
>
> To subscribe to the list, send a message to:
>
>
> To remove
; Hi,
> I am interested in Kafka, I want to subscribe kafka mail lists, Thanks.
>
Hi,
I am interested in Kafka, I want to subscribe kafka mail lists, Thanks.
On Mon, Aug 18, 2014 at 4:55 PM, Neha Narkhede
wrote:
> Here are instructions on how to subscribe correctly -
> http://kafka.apache.org/contact.html
>
>
> On Mon, Aug 18, 2014 at 5:41 AM, Nishit Kumar
> wrote:
>
> >
> >
>
Here are instructions on how to subscribe correctly -
http://kafka.apache.org/contact.html
On Mon, Aug 18, 2014 at 5:41 AM, Nishit Kumar wrote:
>
>
1 - 100 of 115 matches
Mail list logo