Re: [onap-discuss] [dmaap] DMaaP API
Yes.
Thanks,
Sunil
From: William Kurkian
Sent: Thursday, June 28, 2018 2:42 PM
To: UNNAVA, SUNIL
Cc: onap-discuss@lists.onap.org
Subject: Re: [onap-discuss] [dmaap] DMaaP API
Ok thank you, I think I understand how it works now. Is this behavior primarily
characteristic of Kafka?
Thanks,
William
On Thu, Jun 28, 2018 at 12:37 PM, UNNAVA, SUNIL
mailto:su6...@att.com>> wrote:
In between the 2 REST subscribe calls with different consumer groups, if the
producer publishes the messages to a topic, the 2nd REST call will not receive
any messages as the 2nd consumer group is not subscribed to a Topic, before the
producer publishes the messages. There is no change in the message received for
any subsequent REST subscribe calls.
Thanks,
Sunil
From: William Kurkian mailto:wkurki...@gmail.com>>
Sent: Thursday, June 28, 2018 11:56 AM
To: UNNAVA, SUNIL mailto:su6...@att.com>>
Cc: onap-discuss@lists.onap.org<mailto:onap-discuss@lists.onap.org>
Subject: Re: [onap-discuss] [dmaap] DMaaP API
Ok, let me see if I understand.
I can subscribe to a topic with this REST call: GET
http(s)://{HOST:PORT}}/events/{topicname}/{consumegroup}/{consumerid}/{timeout=x}.
Once the client gets a response with messages, they issue another REST call to
wait for more.
At the same time there is another client also issuing calls. Naturally, they
are not issuing calls at the exact same time.
Based on what I am seeing in my terminal, they may not both receive some
messages if the other one has not received it, even if they use different
consumer groups.
Is there something I am not understanding in this ?
Thanks,
William
-=-=-=-=-=-=-=-=-=-=-=-
Links: You receive all messages sent to this group.
View/Reply Online (#10682): https://lists.onap.org/g/onap-discuss/message/10682
Mute This Topic: https://lists.onap.org/mt/22867594/21656
Group Owner: onap-discuss+ow...@lists.onap.org
Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub
[arch...@mail-archive.com]
-=-=-=-=-=-=-=-=-=-=-=-
Re: [onap-discuss] [dmaap] DMaaP API
Ok thank you, I think I understand how it works now. Is this behavior
primarily characteristic of Kafka?
Thanks,
William
On Thu, Jun 28, 2018 at 12:37 PM, UNNAVA, SUNIL wrote:
> In between the 2 REST subscribe calls with different consumer groups, if
> the producer publishes the messages to a topic, the 2nd REST call will
> not receive any messages as the 2nd consumer group is not subscribed to a
> Topic, before the producer publishes the messages. There is no change in
> the message received for any subsequent REST subscribe calls.
>
>
>
>
>
> Thanks,
>
> Sunil
>
>
>
> *From:* William Kurkian
> *Sent:* Thursday, June 28, 2018 11:56 AM
> *To:* UNNAVA, SUNIL
> *Cc:* onap-discuss@lists.onap.org
> *Subject:* Re: [onap-discuss] [dmaap] DMaaP API
>
>
>
> Ok, let me see if I understand.
>
>
>
> I can subscribe to a topic with this REST call: GET
> http(s)://{HOST:PORT}}/events/{topicname}/{consumegroup}/{
> consumerid}/{timeout=x}.
>
>
>
> Once the client gets a response with messages, they issue another REST
> call to wait for more.
>
> At the same time there is another client also issuing calls. Naturally,
> they are not issuing calls at the exact same time.
>
>
>
> Based on what I am seeing in my terminal, they may not both receive some
> messages if the other one has not received it, even if they use different
> consumer groups.
>
>
>
> Is there something I am not understanding in this ?
>
>
>
> Thanks,
>
> William
>
-=-=-=-=-=-=-=-=-=-=-=-
Links: You receive all messages sent to this group.
View/Reply Online (#10681): https://lists.onap.org/g/onap-discuss/message/10681
Mute This Topic: https://lists.onap.org/mt/22867594/21656
Group Owner: onap-discuss+ow...@lists.onap.org
Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub
[arch...@mail-archive.com]
-=-=-=-=-=-=-=-=-=-=-=-
Re: [onap-discuss] [dmaap] DMaaP API
In between the 2 REST subscribe calls with different consumer groups, if the
producer publishes the messages to a topic, the 2nd REST call will not receive
any messages as the 2nd consumer group is not subscribed to a Topic, before the
producer publishes the messages. There is no change in the message received for
any subsequent REST subscribe calls.
Thanks,
Sunil
From: William Kurkian
Sent: Thursday, June 28, 2018 11:56 AM
To: UNNAVA, SUNIL
Cc: onap-discuss@lists.onap.org
Subject: Re: [onap-discuss] [dmaap] DMaaP API
Ok, let me see if I understand.
I can subscribe to a topic with this REST call: GET
http(s)://{HOST:PORT}}/events/{topicname}/{consumegroup}/{consumerid}/{timeout=x}.
Once the client gets a response with messages, they issue another REST call to
wait for more.
At the same time there is another client also issuing calls. Naturally, they
are not issuing calls at the exact same time.
Based on what I am seeing in my terminal, they may not both receive some
messages if the other one has not received it, even if they use different
consumer groups.
Is there something I am not understanding in this ?
Thanks,
William
-=-=-=-=-=-=-=-=-=-=-=-
Links: You receive all messages sent to this group.
View/Reply Online (#10675): https://lists.onap.org/g/onap-discuss/message/10675
Mute This Topic: https://lists.onap.org/mt/22867594/21656
Group Owner: onap-discuss+ow...@lists.onap.org
Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub
[arch...@mail-archive.com]
-=-=-=-=-=-=-=-=-=-=-=-
Re: [onap-discuss] [dmaap] DMaaP API
Ok, let me see if I understand.
I can subscribe to a topic with this REST call: GET
http(s)://{HOST:PORT}}/events/{topicname}/{consumegroup}/{consumerid}/{timeout=x}.
Once the client gets a response with messages, they issue another REST call
to wait for more.
At the same time there is another client also issuing calls. Naturally,
they are not issuing calls at the exact same time.
Based on what I am seeing in my terminal, they may not both receive some
messages if the other one has not received it, even if they use different
consumer groups.
Is there something I am not understanding in this ?
Thanks,
William
-=-=-=-=-=-=-=-=-=-=-=-
Links: You receive all messages sent to this group.
View/Reply Online (#10671): https://lists.onap.org/g/onap-discuss/message/10671
Mute This Topic: https://lists.onap.org/mt/22867594/21656
Group Owner: onap-discuss+ow...@lists.onap.org
Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub
[arch...@mail-archive.com]
-=-=-=-=-=-=-=-=-=-=-=-
Re: [onap-discuss] [dmaap] DMaaP API
Message Router is the REST API created around Kafka. It internally uses the Kaka API. Thanks, Sunil From: William Kurkian Sent: Thursday, June 28, 2018 11:44 AM To: UNNAVA, SUNIL Cc: onap-discuss@lists.onap.org Subject: Re: [onap-discuss] [dmaap] DMaaP API I was using the message-router to do this. Do you mean I can treat this port like a Kafka broker ? Thanks, William On Thu, Jun 28, 2018 at 11:39 AM, UNNAVA, SUNIL mailto:su6...@att.com>> wrote: William, In Kafka, to receive messages published to a topic, subscriber must create a subscription to that topic. Subscriber receives the messages that are published only after subscribing to a topic. If 2 consumer groups want to receive the same messages , they must subscribe to a topic at the same time. Thanks, Sunil From: onap-discuss@lists.onap.org<mailto:onap-discuss@lists.onap.org> mailto:onap-discuss@lists.onap.org>> On Behalf Of William Kurkian Sent: Thursday, June 28, 2018 11:11 AM To: onap-discuss@lists.onap.org<mailto:onap-discuss@lists.onap.org> Subject: [onap-discuss] [dmaap] DMaaP API Hello, I am looking at the DMaaP, and how to subscribe to a topic on it. I have been testing out the REST API like so: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group1/2<https://urldefense.proofpoint.com/v2/url?u=http-3A__10.42.14.190-3A3904_events_unauthenticated.SEC-5FFAULT-5FOUTPUT_group1_2=DwMFaQ=LFYZ-o9_HUMeMTSQicvjIg=t27CRRmn7U12dnOvcSPfcQ=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U=JwAzdo_fwuxwNYiA_CC5FILH3TFAjBbbvBZoG7ojFmw=> This successfully gets messages. The problem I have, is that if issue it for a different consumer group: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group2/3<https://urldefense.proofpoint.com/v2/url?u=http-3A__10.42.14.190-3A3904_events_unauthenticated.SEC-5FFAULT-5FOUTPUT_group2_3=DwMFaQ=LFYZ-o9_HUMeMTSQicvjIg=t27CRRmn7U12dnOvcSPfcQ=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U=KxCsy5YMSaWgCiU48NZ56gBn2IPlmV9MmskWDWI2a2w=> it doesn't return the same message. It works if I wait for a new message, but not to get the same ones. How can I get refetch messages that I've already received? For example, if there were two subscribers, how could they both get the same messages? Thanks, William -=-=-=-=-=-=-=-=-=-=-=- Links: You receive all messages sent to this group. View/Reply Online (#10670): https://lists.onap.org/g/onap-discuss/message/10670 Mute This Topic: https://lists.onap.org/mt/22867594/21656 Group Owner: onap-discuss+ow...@lists.onap.org Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub [arch...@mail-archive.com] -=-=-=-=-=-=-=-=-=-=-=-
Re: [onap-discuss] [dmaap] DMaaP API
William, In Kafka, to receive messages published to a topic, subscriber must create a subscription to that topic. Subscriber receives the messages that are published only after subscribing to a topic. If 2 consumer groups want to receive the same messages , they must subscribe to a topic at the same time. Thanks, Sunil From: onap-discuss@lists.onap.org On Behalf Of William Kurkian Sent: Thursday, June 28, 2018 11:11 AM To: onap-discuss@lists.onap.org Subject: [onap-discuss] [dmaap] DMaaP API Hello, I am looking at the DMaaP, and how to subscribe to a topic on it. I have been testing out the REST API like so: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group1/2<https://urldefense.proofpoint.com/v2/url?u=http-3A__10.42.14.190-3A3904_events_unauthenticated.SEC-5FFAULT-5FOUTPUT_group1_2=DwMFaQ=LFYZ-o9_HUMeMTSQicvjIg=t27CRRmn7U12dnOvcSPfcQ=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U=JwAzdo_fwuxwNYiA_CC5FILH3TFAjBbbvBZoG7ojFmw=> This successfully gets messages. The problem I have, is that if issue it for a different consumer group: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group2/3<https://urldefense.proofpoint.com/v2/url?u=http-3A__10.42.14.190-3A3904_events_unauthenticated.SEC-5FFAULT-5FOUTPUT_group2_3=DwMFaQ=LFYZ-o9_HUMeMTSQicvjIg=t27CRRmn7U12dnOvcSPfcQ=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U=KxCsy5YMSaWgCiU48NZ56gBn2IPlmV9MmskWDWI2a2w=> it doesn't return the same message. It works if I wait for a new message, but not to get the same ones. How can I get refetch messages that I've already received? For example, if there were two subscribers, how could they both get the same messages? Thanks, William -=-=-=-=-=-=-=-=-=-=-=- Links: You receive all messages sent to this group. View/Reply Online (#10668): https://lists.onap.org/g/onap-discuss/message/10668 Mute This Topic: https://lists.onap.org/mt/22867594/21656 Group Owner: onap-discuss+ow...@lists.onap.org Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub [arch...@mail-archive.com] -=-=-=-=-=-=-=-=-=-=-=-
[onap-discuss] [dmaap] DMaaP API
Hello, I am looking at the DMaaP, and how to subscribe to a topic on it. I have been testing out the REST API like so: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group1/2 This successfully gets messages. The problem I have, is that if issue it for a different consumer group: curl http://10.42.14.190:3904/events/unauthenticated.SEC_FAULT_OUTPUT/group2/3 it doesn't return the same message. It works if I wait for a new message, but not to get the same ones. How can I get refetch messages that I've already received? For example, if there were two subscribers, how could they both get the same messages? Thanks, William -=-=-=-=-=-=-=-=-=-=-=- Links: You receive all messages sent to this group. View/Reply Online (#10665): https://lists.onap.org/g/onap-discuss/message/10665 Mute This Topic: https://lists.onap.org/mt/22867594/21656 Group Owner: onap-discuss+ow...@lists.onap.org Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub [arch...@mail-archive.com] -=-=-=-=-=-=-=-=-=-=-=-
