Dixit Singla

@sanjuthomas Does marklogic kafka connector now supports ml.connection.url property. In our case we need to get the data from kafka and then store to Marklogic through custom end point (Wanted...

In our case, we dropped the idea of using the batching mechanism in parallel consumer. But while doing analysis I have few observations given below. - If you are using...

I am trying to implement the parallel consumer in spring boot and using the above mentioned way. I have main class in separate java file and rest of the methods(KafkaListener,...

Thank for the correcting the type(exits). I was able to run the application by specifying `@Autowired` annotation for the `ApplicationRunner runner(` method. Although I have tried `@Configuration` annotation as well...

As you stated earlier 'You don't need your own consumer factory bean, just use Boot's.' I have just observed that the runner method is using the spring boot's consumer factory...

As of now I am trying with the spring boot's consumer factory. My application is stuck at `2023-07-03 22:19:38.423 INFO 40836 --- [ pc-broker-poll] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-group-1, groupId=group] Resetting...

Sorry, did not get what do you mean by container. I am running the application in Intellij idea and the Kafka is up and running.

Do you mean by setting the `autoStartup='true'` - But in that case you have said earlier that auto setup should be set to false to invoke the parallel consumer.

Could you please help me in understanding why `listen` method is not called, what needs to be done to make it working. Ideally it should call the listen method as...

> You have to start the container to consume. After adding the below line I was able to consume the messages. but each message is being consumed 2 times,, Could...