Hi Mikael, in previous releases, as you already stated the VES collector is depending on the DMaaP MR for sending it’s events. In the coming version (see https://git.onap.org/oom/commit/kubernetes/dcaegen2-services/components/dcae-ves-collector?id=ad8e7c7a9b5da7c348d9c1c6a3eda61f49301150) We implement change to use native Kafka interface. So you can use the Helmchart version 13.1.0 of the VES collector.
Best regards Andreas Von: [email protected] <[email protected]> Im Auftrag von [email protected] Gesendet: Mittwoch, 20. März 2024 14:05 An: [email protected]; [email protected] Betreff: Re: [onap-discuss] Questions about dcaegen2-collectors-ves Hi again, Got progress and tried with the an example of measurement in the repo. https://github.com/onap/dcaegen2-collectors-ves/blob/master/src/test/resources/measurement7x.json I could see in log that it worked and then I got error that it could not be published. java.lang.NullPointerException: null at org.onap.dcae.common.publishing.Publisher.publishEvents(Publisher.java:62) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.common.publishing.Publisher.publishEvents(Publisher.java:57) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.common.publishing.DMaaPEventPublisher.messageRouterPublishResponse(DMaaPEventPublisher.java:69) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.common.publishing.DMaaPEventPublisher.sendEvent(DMaaPEventPublisher.java:63) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.common.EventSender.send(EventSender.java:55) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.restapi.VesRestController.handleEvent(VesRestController.java:118) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.restapi.VesRestController.process(VesRestController.java:107) ~[VESCollector-1.12.4.jar:?] at org.onap.dcae.restapi.VesRestController.event(VesRestController.java:89) ~[VESCollector-1.12.4.jar:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] at java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-5.3.22.jar:5.3.22] at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) ~[spring-web-5.3.22.jar:5.3.22] at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1070) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.3.22.jar:5.3.22] at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909) ~[spring-webmvc-5.3.22.jar:5.3.22] at javax.servlet.http.HttpServlet.service(HttpServlet.java:681) ~[tomcat-embed-core-9.0.65.jar:4.0.FR] at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.3.22.jar:5.3.22] at javax.servlet.http.HttpServlet.service(HttpServlet.java:764) ~[tomcat-embed-core-9.0.65.jar:4.0.FR] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227) ~[tomcat-embed-core-9.0.65.jar:9.0.65] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.65.jar:9.0.65] But that is ok too since we don't have a DMaaP. We want to use kafka. What do we need to set in in collector ves to send to kafka. I was thinking I can use a kafka consumer to listen to these events. Would that be possible? br. //mikael -=-=-=-=-=-=-=-=-=-=-=- Links: You receive all messages sent to this group. View/Reply Online (#24646): https://lists.onap.org/g/onap-discuss/message/24646 Mute This Topic: https://lists.onap.org/mt/103992338/21656 Group Owner: [email protected] Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub [[email protected]] -=-=-=-=-=-=-=-=-=-=-=-
