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: [email protected] <[email protected]> On Behalf Of William Kurkian Sent: Thursday, June 28, 2018 11:11 AM To: [email protected] 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&d=DwMFaQ&c=LFYZ-o9_HUMeMTSQicvjIg&r=t27CRRmn7U12dnOvcSPfcQ&m=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U&s=JwAzdo_fwuxwNYiA_CC5FILH3TFAjBbbvBZoG7ojFmw&e=> 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&d=DwMFaQ&c=LFYZ-o9_HUMeMTSQicvjIg&r=t27CRRmn7U12dnOvcSPfcQ&m=liq6PDAGgzFuHzhiJilLGqs0hm-IGLc2re6TATekn5U&s=KxCsy5YMSaWgCiU48NZ56gBn2IPlmV9MmskWDWI2a2w&e=> 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: [email protected] Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub [[email protected]] -=-=-=-=-=-=-=-=-=-=-=-
