+
+ private void preCreateOffsetTopic(InputStream msg) {
+
+ try {
+ eventsService.pushEvents(getDmaapContext(), "DUMMY_TOPIC", msg, null, null);
+ eventsService.getEvents(getDmaapContext(), "DUMMY_TOPIC", "CG1", "C1");
+ isOffsetTopicCreated = true;
+ } catch (CambriaApiException | ConfigDbException | AccessDeniedException | TopicExistsException | IOException
+ | missingReqdSetting | UnavailableException e) {
+ log.error("Error while creating the dummy topic", e);
+ }
+
+ }