Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2791

Hi all, I am trying to connect the my spring boot application with debezium mongodb connector. i have added the all the related properties

    XMLWordPrintable

Details

    • Enhancement
    • Resolution: Won't Do
    • Major
    • None
    • 1.4.0.Alpha2
    • mongodb-connector
    • None
    • False
    • False
    • Undefined

    Description

      The below properties i have added in application.properties

      cdc.name = solution
      cdc.connector= io.debezium.connector.mongodb.MongoDbConnector
      cdc.tasks.max = 1
      cdc.server.name=my-app-connector
      cdc.mongodb.hosts = rs0/127.0.0.1:27019
      cdc.mongodb.user = debezium
      cdc.mongodb.password = dbz
      cdc.database.history.kafka.bootstrap.servers = kafka:9092
      cdc.offset.flush.interval.ms=60000
      cdc.server.id=85744
      cdc.filtering.enabled=false
      cdc.includeSchema=false
      spring.main.allow-bean-definition-overriding=true

       

      And the following dependencies i added in pom.xml file.

      <dependency>
      <groupId>org.springframework.cloud.stream.app</groupId>
      <artifactId>cdc-debezium-spring-boot-starter</artifactId>
      <version>1.0.4.RELEASE</version>
      </dependency>

       

      The error logs are:

       

      0:51:52.596 [pool-1-thread-1] ERROR i.d.c.mongodb.MongoDbConnector - The 'mongodb.hosts' value is invalid: Host specification is required0:51:52.596 [pool-1-thread-1] ERROR i.d.c.mongodb.MongoDbConnector - The 'mongodb.hosts' value is invalid: Host specification is required10:51:52.596 [pool-1-thread-1] ERROR i.d.c.mongodb.MongoDbConnector - The 'mongodb.name' value is invalid: A value is required10:51:52.601 [pool-1-thread-1] INFO  i.d.c.mongodb.MongoDbConnector - Stopping MongoDB connector10:51:52.602 [pool-1-thread-1] INFO  i.d.c.mongodb.MongoDbConnector - Stopped MongoDB connector10:51:52.604 [pool-1-thread-1] ERROR o.s.c.s.a.c.c.core.EmbeddedEngine - Error while trying to run connector class 'io.debezium.connector.mongodb.MongoDbConnector'org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of MongoDbConnector; check the logs for details at io.debezium.connector.mongodb.MongoDbConnector.start(MongoDbConnector.java:106) at org.springframework.cloud.stream.app.cdc.common.core.EmbeddedEngine.run(EmbeddedEngine.java:786) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630) at java.base/java.lang.Thread.run(Thread.java:832)10:51:53.187 [restartedMain] WARN  o.s.b.w.s.c.AnnotationConfigServletWebServerApplicationContext - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'functionCatalog' defined in class path resource [org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.cloud.function.context.FunctionRegistry]: Factory method 'functionCatalog' threw exception; nested exception is java.lang.IllegalStateException: No bean class specified on bean definition10:51:53.193 [restartedMain] WARN  o.s.b.f.s.DisposableBeanAdapter - Invocation of destroy method failed on bean with name 'tomcatMetricsBinder': java.lang.NullPointerException: Cannot invoke "io.micrometer.core.instrument.binder.tomcat.TomcatMetrics.close()" because "this.tomcatMetrics" is null10:51:53.194 [restartedMain] INFO  c.autoconfigure.CdcAutoConfiguration - Stop Embedded Engine10:51:53.195 [restartedMain] INFO  o.s.s.c.ThreadPoolTaskExecutor - Shutting down ExecutorService 'applicationTaskExecutor'10:51:53.197 [restartedMain] INFO  org.mongodb.driver.connection - Closed connection [connectionId\{localValue:5, serverValue:154}] to localhost:27017 because the pool has been closed.10:51:53.213 [restartedMain] INFO  o.a.catalina.core.StandardService - Stopping service [Tomcat]10:51:53.315 [restartedMain] INFO  o.s.b.a.l.ConditionEvaluationReportLoggingListener - 
      Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.10:51:53.317 [restartedMain] ERROR o.s.boot.SpringApplication - Application run failedorg.springframework.beans.factory.BeanCreationException: Error creating bean with name 'functionCatalog' defined in class path resource [org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.cloud.function.context.FunctionRegistry]: Factory method 'functionCatalog' threw exception; nested exception is java.lang.IllegalStateException: No bean class specified on bean definition at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:656) at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:636) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1338) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1177) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:557) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:517) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:323) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:321) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:882) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:878) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215) at com.digitaldots.foundation.FoundationApplication.main(FoundationApplication.java:28) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:64) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:564) at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49)Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.cloud.function.context.FunctionRegistry]: Factory method 'functionCatalog' threw exception; nested exception is java.lang.IllegalStateException: No bean class specified on bean definition at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185) at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:651) ... 24 common frames omittedCaused by: java.lang.IllegalStateException: No bean class specified on bean definition at org.springframework.beans.factory.support.AbstractBeanDefinition.getBeanClass(AbstractBeanDefinition.java:423) at org.springframework.cloud.function.context.config.FunctionContextUtils.findType(FunctionContextUtils.java:70) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$ContextFunctionRegistry.findType(ContextFunctionCatalogAutoConfiguration.java:586) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$ContextFunctionRegistry.wrap(ContextFunctionCatalogAutoConfiguration.java:460) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$ContextFunctionRegistry.lambda$merge$6(ContextFunctionCatalogAutoConfiguration.java:438) at java.base/java.lang.Iterable.forEach(Iterable.java:75) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$ContextFunctionRegistry.merge(ContextFunctionCatalogAutoConfiguration.java:438) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration.functionCatalog(ContextFunctionCatalogAutoConfiguration.java:111) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$$EnhancerBySpringCGLIB$$af3b4b67.CGLIB$functionCatalog$0(<generated>) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$$EnhancerBySpringCGLIB$$af3b4b67$$FastClassBySpringCGLIB$$f8bf01de.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244) at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331) at org.springframework.cloud.function.context.config.ContextFunctionCatalogAutoConfiguration$$EnhancerBySpringCGLIB$$af3b4b67.functionCatalog(<generated>) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:64) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:564) at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154) ... 25 common frames omitted
      Process finished with exit code 0.

       

      Can anyone pls help what are the exact configurations i should add. Thanks in advance

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            dhayakar Dhayakar K (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: