search

QNJR-GROUP / EasyTransaction

A distribute transaction solution（分布式事务） unified the usage of TCC , SAGA ,FMT (seata/fescar AutoCompensation)， reliable message, compensate and so on;
Apache License 2.0
2.36k stars 808 forks source link

UT中的案例运行环境问题 #18

Closed jackBaozz closed 6 years ago

jackBaozz commented 6 years ago

目前看到UT中的例子了，想自己测试一下，总是差一些东西运行不了。 还请作者能够说明一下运行这些UT例子都配置了其他什么服务具体参数，以及作者的测试环境和步骤。 目前只能先看，还运行不起来UT的例子

：（

skyesx commented 6 years ago

贴一下报错？

jackBaozz commented 6 years ago

@skyesx

2017-12-22 14:00:52.411 INFO 13200 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 1.0.0 2017-12-22 14:00:52.411 INFO 13200 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : aaa7af6d4a11b29d 2017-12-22 14:05:57.411 WARN 13200 --- [ main] s.c.a.AnnotationConfigApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'easyTransMsgConsumerImpl' defined in com.yiqiniu.easytrans.queue.impl.kafka.KafkaQueueConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata 2017-12-22 14:05:57.413 DEBUG 13200 --- [ main] .b.l.ClasspathLoggingApplicationListener : Application failed to start with classpath: [file:/E:/Program%20Files/JetBrains/IntelliJ%20IDEA%202017.3/lib/idea_rt.jar, file:/E:/Program%20Files/JetBrains/IntelliJ%20IDEA%202017.3/plugins/junit/lib/junit-rt.jar, file:/E:/Program%20Files/JetBrains/IntelliJ%20IDEA%202017.3/plugins/junit/lib/junit5-rt.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/charsets.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/deploy.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/access-bridge-64.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/cldrdata.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/dnsns.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/jaccess.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/jfxrt.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/localedata.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/nashorn.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/sunec.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/sunjce_provider.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/sunmscapi.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/sunpkcs11.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/ext/zipfs.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/javaws.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/jce.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/jfr.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/jfxswt.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/jsse.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/management-agent.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/plugin.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/resources.jar, file:/E:/Program%20Files/Java/jdk1.8.0_144/jre/lib/rt.jar, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-starter/target/test-classes/, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-starter/target/classes/, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-core/target/classes/, file:/E:/maven/repository/org/springframework/boot/spring-boot-starter/1.5.6.RELEASE/spring-boot-starter-1.5.6.RELEASE.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot/1.5.6.RELEASE/spring-boot-1.5.6.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-context/4.3.10.RELEASE/spring-context-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-aop/4.3.10.RELEASE/spring-aop-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-expression/4.3.10.RELEASE/spring-expression-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot-autoconfigure/1.5.6.RELEASE/spring-boot-autoconfigure-1.5.6.RELEASE.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot-starter-logging/1.5.6.RELEASE/spring-boot-starter-logging-1.5.6.RELEASE.jar, file:/E:/maven/repository/ch/qos/logback/logback-classic/1.1.11/logback-classic-1.1.11.jar, file:/E:/maven/repository/ch/qos/logback/logback-core/1.1.11/logback-core-1.1.11.jar, file:/E:/maven/repository/org/slf4j/jcl-over-slf4j/1.7.25/jcl-over-slf4j-1.7.25.jar, file:/E:/maven/repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25.jar, file:/E:/maven/repository/org/slf4j/log4j-over-slf4j/1.7.25/log4j-over-slf4j-1.7.25.jar, file:/E:/maven/repository/org/yaml/snakeyaml/1.17/snakeyaml-1.17.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot-configuration-processor/1.5.6.RELEASE/spring-boot-configuration-processor-1.5.6.RELEASE.jar, file:/E:/maven/repository/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1.jar, file:/E:/maven/repository/org/springframework/spring-jdbc/4.3.10.RELEASE/spring-jdbc-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-beans/4.3.10.RELEASE/spring-beans-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-tx/4.3.10.RELEASE/spring-tx-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/apache/curator/curator-recipes/2.11.1/curator-recipes-2.11.1.jar, file:/E:/maven/repository/org/apache/curator/curator-framework/2.11.1/curator-framework-2.11.1.jar, file:/E:/maven/repository/org/apache/curator/curator-client/2.11.1/curator-client-2.11.1.jar, file:/E:/maven/repository/org/apache/zookeeper/zookeeper/3.4.8/zookeeper-3.4.8.jar, file:/E:/maven/repository/jline/jline/0.9.94/jline-0.9.94.jar, file:/E:/maven/repository/com/google/guava/guava/18.0/guava-18.0.jar, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-log-kafka-starter/target/classes/, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-queue-kafka-starter/target/classes/, file:/E:/maven/repository/org/apache/kafka/kafka-clients/1.0.0/kafka-clients-1.0.0.jar, file:/E:/maven/repository/org/lz4/lz4-java/1.4/lz4-java-1.4.jar, file:/E:/maven/repository/org/xerial/snappy/snappy-java/1.1.4/snappy-java-1.1.4.jar, file:/E:/maven/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-rpc-feign-starter/target/classes/, file:/E:/maven/repository/org/springframework/boot/spring-boot-starter-test/1.5.6.RELEASE/spring-boot-starter-test-1.5.6.RELEASE.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot-test/1.5.6.RELEASE/spring-boot-test-1.5.6.RELEASE.jar, file:/E:/maven/repository/org/springframework/boot/spring-boot-test-autoconfigure/1.5.6.RELEASE/spring-boot-test-autoconfigure-1.5.6.RELEASE.jar, file:/E:/maven/repository/com/jayway/jsonpath/json-path/2.2.0/json-path-2.2.0.jar, file:/E:/maven/repository/net/minidev/json-smart/2.2.1/json-smart-2.2.1.jar, file:/E:/maven/repository/net/minidev/accessors-smart/1.1/accessors-smart-1.1.jar, file:/E:/maven/repository/org/ow2/asm/asm/5.0.3/asm-5.0.3.jar, file:/E:/maven/repository/junit/junit/4.12/junit-4.12.jar, file:/E:/maven/repository/org/assertj/assertj-core/2.6.0/assertj-core-2.6.0.jar, file:/E:/maven/repository/org/mockito/mockito-core/1.10.19/mockito-core-1.10.19.jar, file:/E:/maven/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar, file:/E:/maven/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar, file:/E:/maven/repository/org/hamcrest/hamcrest-library/1.3/hamcrest-library-1.3.jar, file:/E:/maven/repository/org/skyscreamer/jsonassert/1.4.0/jsonassert-1.4.0.jar, file:/E:/maven/repository/org/springframework/spring-core/4.3.10.RELEASE/spring-core-4.3.10.RELEASE.jar, file:/E:/maven/repository/org/springframework/spring-test/4.3.10.RELEASE/spring-test-4.3.10.RELEASE.jar, file:/E:/maven/repository/mysql/mysql-connector-java/5.1.43/mysql-connector-java-5.1.43.jar, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-log-database-starter/target/classes/, file:/E:/maven/repository/com/alibaba/druid/1.1.5/druid-1.1.5.jar, file:/E:/Users/IdeaProjects/EasyTransaction/easytrans-rpc-dubbo-starter/target/classes/, file:/E:/maven/repository/com/alibaba/dubbo/2.5.3/dubbo-2.5.3.jar, file:/E:/maven/repository/org/springframework/spring/2.5.6.SEC03/spring-2.5.6.SEC03.jar, file:/E:/maven/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar, file:/E:/maven/repository/org/javassist/javassist/3.21.0-GA/javassist-3.21.0-GA.jar, file:/E:/maven/repository/org/jboss/netty/netty/3.2.5.Final/netty-3.2.5.Final.jar, file:/E:/maven/repository/com/101tec/zkclient/0.4/zkclient-0.4.jar, file:/E:/maven/repository/log4j/log4j/1.2.14/log4j-1.2.14.jar, file:/C:/Users/Administrator/.IntelliJIdea2017.3/system/captureAgent/debugger-agent.jar, file:/E:/Program%20Files/JetBrains/IntelliJ%20IDEA%202017.3/lib/asm-all.jar] 2017-12-22 14:05:57.418 DEBUG 13200 --- [ main] utoConfigurationReportLoggingInitializer :

========================= AUTO-CONFIGURATION REPORT

Positive matches:

DataBaseTransactionLogConfiguration matched:

Negative matches:

EasyTransCoreConfiguration#singleDataSourceSelector: Did not match:

Exclusions:

None

Unconditional classes:

None

2017-12-22 14:05:57.427 ERROR 13200 --- [ main] o.s.boot.SpringApplication : Application startup failed

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'easyTransMsgConsumerImpl' defined in com.yiqiniu.easytrans.queue.impl.kafka.KafkaQueueConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:599) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1173) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1067) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:513) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867) ~[spring-context-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:543) ~[spring-context-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:303) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:120) [spring-boot-test-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:98) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:116) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:83) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener.outputConditionEvaluationReport(SpringBootDependencyInjectionTestExecutionListener.java:54) [spring-boot-test-autoconfigure-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener.prepareTestInstance(SpringBootDependencyInjectionTestExecutionListener.java:47) [spring-boot-test-autoconfigure-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:230) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:228) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:287) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:289) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:247) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runners.ParentRunner.run(ParentRunner.java:363) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runner.JUnitCore.run(JUnitCore.java:137) [junit-4.12.jar:4.12] at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) [junit-rt.jar:na] at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47) [junit-rt.jar:na] at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) [junit-rt.jar:na] at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) [junit-rt.jar:na] Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:189) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] ... 41 common frames omitted Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

2017-12-22 14:05:57.433 ERROR 13200 --- [ main] o.s.test.context.TestContextManager : Caught exception while allowing TestExecutionListener [org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener@3d34d211] to prepare test instance [com.yiqiniu.easytrans.test.FullTest@50caa560]

java.lang.IllegalStateException: Failed to load ApplicationContext at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:124) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:83) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.injectDependencies(DependencyInjectionTestExecutionListener.java:117) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.prepareTestInstance(DependencyInjectionTestExecutionListener.java:83) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener.prepareTestInstance(SpringBootDependencyInjectionTestExecutionListener.java:44) ~[spring-boot-test-autoconfigure-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:230) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:228) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:287) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:289) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:247) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) [junit-4.12.jar:4.12] at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runners.ParentRunner.run(ParentRunner.java:363) [junit-4.12.jar:4.12] at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191) [spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.junit.runner.JUnitCore.run(JUnitCore.java:137) [junit-4.12.jar:4.12] at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) [junit-rt.jar:na] at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47) [junit-rt.jar:na] at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) [junit-rt.jar:na] at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) [junit-rt.jar:na] Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'easyTransMsgConsumerImpl' defined in com.yiqiniu.easytrans.queue.impl.kafka.KafkaQueueConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:599) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1173) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1067) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:513) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867) ~[spring-context-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:543) ~[spring-context-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:303) ~[spring-boot-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:120) ~[spring-boot-test-1.5.6.RELEASE.jar:1.5.6.RELEASE] at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:98) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:116) ~[spring-test-4.3.10.RELEASE.jar:4.3.10.RELEASE] ... 25 common frames omitted Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:189) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588) ~[spring-beans-4.3.10.RELEASE.jar:4.3.10.RELEASE] ... 42 common frames omitted Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

java.lang.IllegalStateException: Failed to load ApplicationContext

at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:124)
at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:83)
at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.injectDependencies(DependencyInjectionTestExecutionListener.java:117)
at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.prepareTestInstance(DependencyInjectionTestExecutionListener.java:83)
at org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener.prepareTestInstance(SpringBootDependencyInjectionTestExecutionListener.java:44)
at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:230)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:228)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:287)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:289)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:247)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)

Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'easyTransMsgConsumerImpl' defined in com.yiqiniu.easytrans.queue.impl.kafka.KafkaQueueConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:599) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1173) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1067) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:513) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:543) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360) at org.springframework.boot.SpringApplication.run(SpringApplication.java:303) at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:120) at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:98) at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:116) ... 25 more Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.yiqiniu.easytrans.queue.impl.kafka.KafkaEasyTransMsgConsumerImpl]: Factory method 'easyTransMsgConsumerImpl' threw exception; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:189) at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588) ... 42 more Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

Disconnected from the target VM, address: '127.0.0.1:52410', transport: 'socket'

Process finished with exit code -1

skyesx commented 6 years ago

需要启动ZK和KAFKA，启动完后，修改配置文件中对应的ZK地址及KAFKA地址

jackBaozz commented 6 years ago

@skyesx 我已经启动了zk和 kafka ,地址都是软件默认 yml文件里面除了修改mysql密码其他都没动.

然后运行的是 FullTest.java文件 2017-12-22 17:53:13.859 INFO 11640 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 1.0.0 2017-12-22 17:53:13.859 INFO 11640 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : aaa7af6d4a11b29d

会在这里卡住,等大概1分钟然后就是说XXXXXbean对象实例初始化失败

skyesx commented 6 years ago

看报错

org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

指代的就是KAFKA服务器连接不上。

这个是KAFKA连接地址的配置项

easytrans.queue.kafka.consumer-cfg.native-cfg.bootstrap.servers

KAFKA启动后，用telnet检查上述配置里的这个地址端口是否可联通

若可联通，easytrans.queue.kafka.consumer-cfg.native-cfg这个参数下放的是原生的KAFKA参数，你试一下用这些参数创建一个官方KAFKA-CLIENT的 CONSUMER，看能否成功。

skyesx commented 6 years ago

无反馈，先关闭，若发现问题可再打开

jackBaozz commented 6 years ago

最近项目忙现在才有时间继续.

  1. 本机环境是 win10, zk和kfk都是安装的windows下在跑. 期间遇到kfk的各种问题,最终还是跑起来了.......

  2. kfk还有个问题, 第一次运行了后打的日志比如在E:\tmp\kafka-logs下,当你关闭运行kfk和zk的窗口后,再启动, kfk就会出一个异常 [2018-01-30 11:25:35,862] INFO Loading logs. (kafka.log.LogManager) [2018-01-30 11:25:35,964] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (E:\tmp\kafka-logs\test1-0\00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting E:\tmp\kafka-logs\test1-0\00000000000000000000.timeindex, E:\tmp\kafka-logs\test1-0\00000000000000000000.index, and E:\tmp\kafka-logs\test1-0\00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-01-30 11:25:35,968] ERROR There was an error in one of the threads during logs loading: java.nio.file.FileSystemException: E:\tmp\kafka-logs\test1-0\00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。 (kafka.log.LogManager) [2018-01-30 11:25:35,976] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) java.nio.file.FileSystemException: E:\tmp\kafka-logs\test1-0\00000000000000000000.timeindex: 另一个程序正在使用此文件， 进程无法访问。

    at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
at sun.nio.fs.WindowsFileSystemProvider.implDelete(WindowsFileSystemProvider.java:269)
at sun.nio.fs.AbstractFileSystemProvider.deleteIfExists(AbstractFileSystemProvider.java:108)
at java.nio.file.Files.deleteIfExists(Files.java:1165)
at kafka.log.Log$$anonfun$loadSegmentFiles$3.apply(Log.scala:318)

必须把E:\tmp\kafka-logs下日志全部清除了再运行,zk和kfk就正常了...

ps;发现一个问题, 在IDEA下调试的时候, 本FullTest.java 调试的时候必须打debug一步一步跟走完才能是sccess ,不然直接run就是error .

还是恳请写个博主自己的环境,安装环境,以及调试步骤方便后来人.