spring-projects / spring-integration

Spring Integration provides an extension of the Spring programming model to support the well-known Enterprise Integration Patterns (EIP)
http://projects.spring.io/spring-integration/
Apache License 2.0
1.54k stars 1.1k forks source link

Http inbound gateway not working when Feign config enabled. #2752

Closed Princelo closed 5 years ago

Princelo commented 5 years ago

Affects Version(s): \


garyrussell commented 5 years ago

You need to provide much more information including your configuration, logs, etc.

artembilan commented 5 years ago

I would treat this as an Invalid one: Spring Integration has no knowledge about Feign. So, this is most likely an issue on that side.

To triage this kind of issues properly I would suggest to start from the StackOverflow.

but I agree with Gary that we (or all others on Feign project side, or on StackOverflow) need much more info to investigate issue and so.

Thanks for understanding.

Princelo commented 5 years ago

It's a Spring Cloud microservice web app built by SpringBoot. We are using Kafka 0.10.1, according to the compatibility matrix, this pom.xml file describes the dependencies:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.10.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.yonyou.occ</groupId>
    <artifactId>davcointegration</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>myintegration</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Edgware.SR2</spring-cloud.version>
        <oracle.version>11.1.0.7.0</oracle.version>
        <iuap.modules.version>3.1.0-RELEASE</iuap.modules.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-integration</artifactId>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-core</artifactId>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-kafka</artifactId>
            <version>2.1.2.RELEASE</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-http</artifactId>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.java-json-tools</groupId>
            <artifactId>json-schema-validator</artifactId>
            <version>2.2.10</version>
        </dependency>
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-kafka</artifactId>
        </dependency>
        <dependency>
            <groupId>de.codecentric</groupId>
            <artifactId>spring-boot-admin-starter-client</artifactId>
            <version>1.5.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>jettison</artifactId>
                    <groupId>org.codehaus.jettison</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>antlr-runtime</artifactId>
                    <groupId>org.antlr</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>com.oracle</groupId>
            <artifactId>ojdbc6</artifactId>
            <version>${oracle.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.0.18</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>1.5.10.RELEASE</version>
                <scope>import</scope>
                <type>pom</type>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

The code works:

                .from(Http.inboundGateway("goods/{operation}")
                        .requestMapping(m -> m.methods(HttpMethod.POST))
                        .requestPayloadType(String.class)
                        .headerExpression(MessageHeaderName.OPERATION, "#pathVariables.operation"))
//......

It still works when @EnableFeignClients add to Spring Boot Application entry. But once the @FeignClient instance wired to(by @Autowired) any config Class(@Configuration), it's not working. I have checked http://myproject/mappings (The request mappings info provided by Spring boot), mappings "/goods/**" disappeared.

Here is logs:


2019-02-16 00:00:00.623  INFO 4326 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@4470f8a6: startup date [Sat Feb 16 00:00:00 CST 2019]; root of context hierarchy
2019-02-16 00:00:01.426  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:01.539  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'configurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$72015540] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::       (v1.5.10.RELEASE)

2019-02-16 00:00:02.488  INFO 4326 --- [           main] c.y.occ.MyIntegrationApplication      : No active profile set, falling back to default profiles: default
2019-02-16 00:00:02.600  INFO 4326 --- [           main] ationConfigEmbeddedWebApplicationContext : Refreshing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@55787112: startup date [Sat Feb 16 00:00:02 CST 2019]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@4470f8a6
2019-02-16 00:00:03.767  INFO 4326 --- [           main] o.s.i.config.IntegrationRegistrar        : No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created.
2019-02-16 00:00:03.802  INFO 4326 --- [           main] o.s.b.f.xml.XmlBeanDefinitionReader      : Loading XML bean definitions from class path resource [applicationContext-persistence.xml]
2019-02-16 00:00:04.504  INFO 4326 --- [           main] o.s.cloud.context.scope.GenericScope     : BeanFactory id=762e3f90-8a50-3596-bb5d-dfaf89988751
2019-02-16 00:00:04.525  INFO 4326 --- [           main] faultConfiguringBeanFactoryPostProcessor : No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created.
2019-02-16 00:00:04.526  INFO 4326 --- [           main] faultConfiguringBeanFactoryPostProcessor : No bean named 'taskScheduler' has been explicitly defined. Therefore, a default ThreadPoolTaskScheduler will be created.
2019-02-16 00:00:04.550  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:04.591  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'com.mycorp.occ.Myintegration.client.BillReceiptClient' of type [org.springframework.cloud.netflix.feign.FeignClientFactoryBean] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.659  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.kafka.annotation.KafkaBootstrapConfiguration' of type [org.springframework.kafka.annotation.KafkaBootstrapConfiguration$$EnhancerBySpringCGLIB$$299963c6] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.725  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration' of type [org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration$$EnhancerBySpringCGLIB$$55e75243] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.840  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationGlobalProperties' of type [org.springframework.beans.factory.config.PropertiesFactoryBean] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.845  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationGlobalProperties' of type [java.util.Properties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.882  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.netflix.metrics.MetricsInterceptorConfiguration$MetricsRestTemplateConfiguration' of type [org.springframework.cloud.netflix.metrics.MetricsInterceptorConfiguration$MetricsRestTemplateConfiguration$$EnhancerBySpringCGLIB$$8813f884] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.904  INFO 4326 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$72015540] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-16 00:00:04.913  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:05.223  INFO 4326 --- [           main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 8066 (http)
2019-02-16 00:00:05.232  INFO 4326 --- [           main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
2019-02-16 00:00:05.233  INFO 4326 --- [           main] org.apache.catalina.core.StandardEngine  : Starting Servlet Engine: Apache Tomcat/8.5.27
2019-02-16 00:00:05.386  INFO 4326 --- [ost-startStop-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
2019-02-16 00:00:05.386  INFO 4326 --- [ost-startStop-1] o.s.web.context.ContextLoader            : Root WebApplicationContext: initialization completed in 2786 ms
2019-02-16 00:00:05.823  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'metricsFilter' to: [/*]
2019-02-16 00:00:05.825  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'characterEncodingFilter' to: [/*]
2019-02-16 00:00:05.825  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
2019-02-16 00:00:05.825  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'httpPutFormContentFilter' to: [/*]
2019-02-16 00:00:05.825  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'requestContextFilter' to: [/*]
2019-02-16 00:00:05.826  INFO 4326 --- [ost-startStop-1] .s.DelegatingFilterProxyRegistrationBean : Mapping filter: 'springSecurityFilterChain' to: [/*]
2019-02-16 00:00:05.826  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'webRequestLoggingFilter' to: [/*]
2019-02-16 00:00:05.827  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean   : Mapping filter: 'applicationContextIdFilter' to: [/*]
2019-02-16 00:00:05.827  INFO 4326 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean  : Mapping servlet: 'dispatcherServlet' to [/]
2019-02-16 00:00:06.400  INFO 4326 --- [           main] o.s.s.c.ThreadPoolTaskScheduler          : Initializing ExecutorService  'taskScheduler'
2019-02-16 00:00:06.446  INFO 4326 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@265a094b: startup date [Sat Feb 16 00:00:06 CST 2019]; parent: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@55787112
2019-02-16 00:00:06.481  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:06.689  INFO 4326 --- [           main] o.a.c.c.C.[Tomcat].[localhost].[/]       : jolokia: No access restrictor found, access to any MBean is allowed
2019-02-16 00:00:08.746  INFO 4326 --- [           main] o.s.s.web.DefaultSecurityFilterChain     : Creating filter chain: org.springframework.security.web.util.matcher.AnyRequestMatcher@1, [org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter@443af394, org.springframework.security.web.context.SecurityContextPersistenceFilter@37ffe4f3, org.springframework.security.web.header.HeaderWriterFilter@6c6379c, org.springframework.security.web.authentication.logout.LogoutFilter@2dc21583, org.springframework.security.web.authentication.www.BasicAuthenticationFilter@25109608, org.springframework.security.web.savedrequest.RequestCacheAwareFilter@202f054f, org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter@640a8f93, org.springframework.security.web.authentication.AnonymousAuthenticationFilter@734f8317, org.springframework.security.web.session.SessionManagementFilter@3739f3c9, org.springframework.security.web.access.ExceptionTranslationFilter@785a4557, org.springframework.security.web.access.intercept.FilterSecurityInterceptor@984de01]
2019-02-16 00:00:08.912  WARN 4326 --- [           main] c.n.c.sources.URLConfigurationSource     : No URLs will be polled as dynamic configuration sources.
2019-02-16 00:00:08.913  INFO 4326 --- [           main] c.n.c.sources.URLConfigurationSource     : To enable URLs as dynamic configuration sources, define System property archaius.configurationSource.additionalUrls or make config.properties available on classpath.
2019-02-16 00:00:08.917  WARN 4326 --- [           main] c.n.c.sources.URLConfigurationSource     : No URLs will be polled as dynamic configuration sources.
2019-02-16 00:00:08.917  INFO 4326 --- [           main] c.n.c.sources.URLConfigurationSource     : To enable URLs as dynamic configuration sources, define System property archaius.configurationSource.additionalUrls or make config.properties available on classpath.
2019-02-16 00:00:09.096  INFO 4326 --- [           main] s.w.s.m.m.a.RequestMappingHandlerAdapter : Looking for @ControllerAdvice: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@55787112: startup date [Sat Feb 16 00:00:02 CST 2019]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@4470f8a6
2019-02-16 00:00:09.184  INFO 4326 --- [           main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/api/base/bill-convert-rules/get-unique-one],methods=[GET]}" onto public abstract org.springframework.http.ResponseEntity<com.mycorp.ocm.common.bills.BillConvertRuleDto> com.mycorp.ocm.common.bills.BillConvertRuleApi.getUniqueOne(java.lang.String,java.lang.String,java.lang.String,java.lang.String)
2019-02-16 00:00:09.187  INFO 4326 --- [           main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error]}" onto public org.springframework.http.ResponseEntity<java.util.Map<java.lang.String, java.lang.Object>> org.springframework.boot.autoconfigure.web.BasicErrorController.error(javax.servlet.http.HttpServletRequest)
2019-02-16 00:00:09.187  INFO 4326 --- [           main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error],produces=[text/html]}" onto public org.springframework.web.servlet.ModelAndView org.springframework.boot.autoconfigure.web.BasicErrorController.errorHtml(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)
2019-02-16 00:00:09.254  INFO 4326 --- [           main] o.s.w.s.handler.SimpleUrlHandlerMapping  : Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-02-16 00:00:09.254  INFO 4326 --- [           main] o.s.w.s.handler.SimpleUrlHandlerMapping  : Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-02-16 00:00:09.408  INFO 4326 --- [           main] o.s.w.s.handler.SimpleUrlHandlerMapping  : Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2019-02-16 00:00:10.526  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/health || /health.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.HealthMvcEndpoint.invoke(javax.servlet.http.HttpServletRequest,java.security.Principal)
2019-02-16 00:00:10.527  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/dump || /dump.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.527  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/auditevents || /auditevents.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public org.springframework.http.ResponseEntity<?> org.springframework.boot.actuate.endpoint.mvc.AuditEventsMvcEndpoint.findByPrincipalAndAfterAndType(java.lang.String,java.util.Date,java.lang.String)
2019-02-16 00:00:10.528  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/logfile || /logfile.json],methods=[GET || HEAD]}" onto public void org.springframework.boot.actuate.endpoint.mvc.LogFileMvcEndpoint.invoke(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse) throws javax.servlet.ServletException,java.io.IOException
2019-02-16 00:00:10.529  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/refresh || /refresh.json],methods=[POST]}" onto public java.lang.Object org.springframework.cloud.endpoint.GenericPostableMvcEndpoint.invoke()
2019-02-16 00:00:10.529  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/mappings || /mappings.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.530  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/trace || /trace.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.531  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/autoconfig || /autoconfig.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.532  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/loggers/{name:.*}],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.LoggersMvcEndpoint.get(java.lang.String)
2019-02-16 00:00:10.533  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/loggers/{name:.*}],methods=[POST],consumes=[application/vnd.spring-boot.actuator.v1+json || application/json],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.LoggersMvcEndpoint.set(java.lang.String,java.util.Map<java.lang.String, java.lang.String>)
2019-02-16 00:00:10.533  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/loggers || /loggers.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.534  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/features || /features.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.535  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/jolokia/**]}" onto public org.springframework.web.servlet.ModelAndView org.springframework.boot.actuate.endpoint.mvc.JolokiaMvcEndpoint.handle(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse) throws java.lang.Exception
2019-02-16 00:00:10.535  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/service-registry/instance-status],methods=[GET]}" onto public org.springframework.http.ResponseEntity org.springframework.cloud.client.serviceregistry.endpoint.ServiceRegistryEndpoint.getStatus()
2019-02-16 00:00:10.536  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/service-registry/instance-status],methods=[POST]}" onto public org.springframework.http.ResponseEntity<?> org.springframework.cloud.client.serviceregistry.endpoint.ServiceRegistryEndpoint.setStatus(java.lang.String)
2019-02-16 00:00:10.537  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/heapdump || /heapdump.json],methods=[GET],produces=[application/octet-stream]}" onto public void org.springframework.boot.actuate.endpoint.mvc.HeapdumpMvcEndpoint.invoke(boolean,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse) throws java.io.IOException,javax.servlet.ServletException
2019-02-16 00:00:10.538  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/metrics/{name:.*}],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.MetricsMvcEndpoint.value(java.lang.String)
2019-02-16 00:00:10.539  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/metrics || /metrics.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.539  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/env],methods=[POST]}" onto public java.lang.Object org.springframework.cloud.context.environment.EnvironmentManagerMvcEndpoint.value(java.util.Map<java.lang.String, java.lang.String>)
2019-02-16 00:00:10.540  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/env/reset],methods=[POST]}" onto public java.util.Map<java.lang.String, java.lang.Object> org.springframework.cloud.context.environment.EnvironmentManagerMvcEndpoint.reset()
2019-02-16 00:00:10.540  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/archaius || /archaius.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.541  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/configprops || /configprops.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.541  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/beans || /beans.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.542  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/info || /info.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.542  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/channels || /channels.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:10.543  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/env/{name:.*}],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EnvironmentMvcEndpoint.value(java.lang.String)
2019-02-16 00:00:10.543  INFO 4326 --- [           main] o.s.b.a.e.mvc.EndpointHandlerMapping     : Mapped "{[/env || /env.json],methods=[GET],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter.invoke()
2019-02-16 00:00:11.033  WARN 4326 --- [           main] arterDeprecationWarningAutoConfiguration : spring-cloud-starter-eureka is deprecated as of Spring Cloud Netflix 1.4.0, please migrate to spring-cloud-starter-netflix-eureka
2019-02-16 00:00:11.110  INFO 4326 --- [           main] o.s.i.codec.kryo.CompositeKryoRegistrar  : configured Kryo registration [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2019-02-16 00:00:11.118  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:11.351  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2019-02-16 00:00:11.354  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'dataSource' has been autodetected for JMX exposure
2019-02-16 00:00:11.368  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'integrationMbeanExporter' has been autodetected for JMX exposure
2019-02-16 00:00:11.374  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'configurationPropertiesRebinder' has been autodetected for JMX exposure
2019-02-16 00:00:11.377  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'refreshEndpoint' has been autodetected for JMX exposure
2019-02-16 00:00:11.379  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'environmentManager' has been autodetected for JMX exposure
2019-02-16 00:00:11.382  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'serviceRegistryEndpoint' has been autodetected for JMX exposure
2019-02-16 00:00:11.383  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'refreshScope' has been autodetected for JMX exposure
2019-02-16 00:00:11.395  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'environmentManager': registering with JMX server as MBean [org.springframework.cloud.context.environment:name=environmentManager,type=EnvironmentManager]
2019-02-16 00:00:11.410  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'serviceRegistryEndpoint': registering with JMX server as MBean [org.springframework.cloud.client.serviceregistry.endpoint:name=serviceRegistryEndpoint,type=ServiceRegistryEndpoint]
2019-02-16 00:00:11.417  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'refreshScope': registering with JMX server as MBean [org.springframework.cloud.context.scope.refresh:name=refreshScope,type=RefreshScope]
2019-02-16 00:00:11.435  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'integrationMbeanExporter': registering with JMX server as MBean [org.springframework.integration.monitor:name=integrationMbeanExporter,type=IntegrationMBeanExporter]
2019-02-16 00:00:11.460  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'configurationPropertiesRebinder': registering with JMX server as MBean [org.springframework.cloud.context.properties:name=configurationPropertiesRebinder,context=55787112,type=ConfigurationPropertiesRebinder]
2019-02-16 00:00:11.463  INFO 4326 --- [           main] o.s.aop.framework.CglibAopProxy          : Final method [private final void com.alibaba.druid.pool.DruidDataSource.decrementPoolingCount()] cannot get proxied via CGLIB: Calls to this method will NOT be routed to the target instance and might lead to NPEs against uninitialized fields in the proxy instance.
2019-02-16 00:00:11.463  INFO 4326 --- [           main] o.s.aop.framework.CglibAopProxy          : Final method [private final void com.alibaba.druid.pool.DruidDataSource.incrementPoolingCount()] cannot get proxied via CGLIB: Calls to this method will NOT be routed to the target instance and might lead to NPEs against uninitialized fields in the proxy instance.
2019-02-16 00:00:11.545  INFO 4326 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'refreshEndpoint': registering with JMX server as MBean [org.springframework.cloud.endpoint:name=refreshEndpoint,type=RefreshEndpoint]
2019-02-16 00:00:11.555  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering beans for JMX exposure on startup
2019-02-16 00:00:11.555  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel notFoundChannel
2019-02-16 00:00:11.558  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=notFoundChannel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=notFoundChannel]
2019-02-16 00:00:11.657  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel output-to-occ-goodsdouhe
2019-02-16 00:00:11.659  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=output-to-occ-goodsdouhe': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=output-to-occ-goodsdouhe]
2019-02-16 00:00:11.667  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel output-to-occ-person
2019-02-16 00:00:11.668  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=output-to-occ-person': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=output-to-occ-person]
2019-02-16 00:00:11.675  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel toOccPerson.input
2019-02-16 00:00:11.677  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=toOccPerson.input': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=toOccPerson.input]
2019-02-16 00:00:11.685  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel person-exception-channel
2019-02-16 00:00:11.687  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=person-exception-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=person-exception-channel]
2019-02-16 00:00:11.693  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel toOccGoods.channel#0
2019-02-16 00:00:11.698  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=toOccGoods.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=toOccGoods.channel#0]
2019-02-16 00:00:11.704  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel person-success-channel
2019-02-16 00:00:11.706  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=person-success-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=person-success-channel]
2019-02-16 00:00:11.713  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel badRequestChannel
2019-02-16 00:00:11.715  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=badRequestChannel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=badRequestChannel]
2019-02-16 00:00:11.721  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personIntegrationFlow.channel#3
2019-02-16 00:00:11.722  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#3': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#3]
2019-02-16 00:00:11.729  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel errorChannel
2019-02-16 00:00:11.730  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=errorChannel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=errorChannel]
2019-02-16 00:00:11.747  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsReceiveFlow.channel#0
2019-02-16 00:00:11.749  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#0]
2019-02-16 00:00:11.757  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsIntegrationFlow.channel#0
2019-02-16 00:00:11.759  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#0]
2019-02-16 00:00:11.765  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel nullChannel
2019-02-16 00:00:11.770  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=nullChannel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=nullChannel]
2019-02-16 00:00:11.782  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsIntegrationFlow.channel#1
2019-02-16 00:00:11.787  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#1': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#1]
2019-02-16 00:00:11.799  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personReceiveFlow.channel#0
2019-02-16 00:00:11.801  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#0]
2019-02-16 00:00:11.807  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goods-success-channel
2019-02-16 00:00:11.808  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goods-success-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goods-success-channel]
2019-02-16 00:00:11.814  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsIntegrationFlow.channel#2
2019-02-16 00:00:11.816  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#2': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#2]
2019-02-16 00:00:11.821  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personReceiveFlow.channel#2
2019-02-16 00:00:11.823  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#2': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#2]
2019-02-16 00:00:11.829  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goods-invalid-channel
2019-02-16 00:00:11.831  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goods-invalid-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goods-invalid-channel]
2019-02-16 00:00:11.836  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personReceiveFlow.channel#3
2019-02-16 00:00:11.838  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#3': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#3]
2019-02-16 00:00:11.844  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personIntegrationFlow.channel#4
2019-02-16 00:00:11.845  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#4': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#4]
2019-02-16 00:00:11.851  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel person-invalid-channel
2019-02-16 00:00:11.852  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=person-invalid-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=person-invalid-channel]
2019-02-16 00:00:11.858  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personReceiveFlow.channel#1
2019-02-16 00:00:11.860  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#1': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personReceiveFlow.channel#1]
2019-02-16 00:00:11.865  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goods-exception-channel
2019-02-16 00:00:11.867  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goods-exception-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goods-exception-channel]
2019-02-16 00:00:11.872  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personReceiveToKafka.input
2019-02-16 00:00:11.874  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personReceiveToKafka.input': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personReceiveToKafka.input]
2019-02-16 00:00:11.884  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personIntegrationFlow.channel#2
2019-02-16 00:00:11.889  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#2': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#2]
2019-02-16 00:00:11.899  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsIntegrationFlow.channel#3
2019-02-16 00:00:11.901  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#3': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#3]
2019-02-16 00:00:11.907  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsReceiveFlow.channel#2
2019-02-16 00:00:11.909  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#2': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#2]
2019-02-16 00:00:11.914  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personIntegrationFlow.channel#0
2019-02-16 00:00:11.916  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#0]
2019-02-16 00:00:11.921  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel personIntegrationFlow.channel#1
2019-02-16 00:00:11.923  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#1': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=personIntegrationFlow.channel#1]
2019-02-16 00:00:11.928  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsReceiveFlow.channel#1
2019-02-16 00:00:11.930  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#1': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#1]
2019-02-16 00:00:11.935  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel toOccPerson.channel#0
2019-02-16 00:00:11.937  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=toOccPerson.channel#0': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=toOccPerson.channel#0]
2019-02-16 00:00:11.942  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsReceiveFlow.channel#3
2019-02-16 00:00:11.944  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#3': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsReceiveFlow.channel#3]
2019-02-16 00:00:11.949  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel person-failure-channel
2019-02-16 00:00:11.951  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=person-failure-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=person-failure-channel]
2019-02-16 00:00:11.956  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsIntegrationFlow.channel#4
2019-02-16 00:00:11.958  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#4': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsIntegrationFlow.channel#4]
2019-02-16 00:00:11.963  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goods-failure-channel
2019-02-16 00:00:11.965  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goods-failure-channel': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goods-failure-channel]
2019-02-16 00:00:11.973  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel goodsReceiveToKafka.input
2019-02-16 00:00:11.975  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=goodsReceiveToKafka.input': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=goodsReceiveToKafka.input]
2019-02-16 00:00:11.987  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel toOccGoods.input
2019-02-16 00:00:11.991  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageChannel,name=toOccGoods.input': registering with JMX server as MBean [org.springframework.integration:type=MessageChannel,name=toOccGoods.input]
2019-02-16 00:00:12.017  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler badRequestChannel
2019-02-16 00:00:12.021  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=badRequestChannel,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=badRequestChannel,bean=anonymous]
2019-02-16 00:00:12.048  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlow.channel#1
2019-02-16 00:00:12.050  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#1,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#1,bean=anonymous]
2019-02-16 00:00:12.055  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlow.channel#2
2019-02-16 00:00:12.057  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#2,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#2,bean=anonymous]
2019-02-16 00:00:12.061  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler toOccGoods.input
2019-02-16 00:00:12.063  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=toOccGoods.input,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=toOccGoods.input,bean=anonymous]
2019-02-16 00:00:12.067  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlowConfig.goodsReceiveFailure.serviceActivator
2019-02-16 00:00:12.069  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodsReceiveFailure.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodsReceiveFailure.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.076  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlow.channel#1
2019-02-16 00:00:12.078  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#1,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#1,bean=anonymous]
2019-02-16 00:00:12.082  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlowConfig.goodslogException.serviceActivator
2019-02-16 00:00:12.084  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodslogException.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodslogException.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.087  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsReceiveFlow.channel#3
2019-02-16 00:00:12.089  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#3,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#3,bean=anonymous]
2019-02-16 00:00:12.094  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlow.channel#0
2019-02-16 00:00:12.096  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.100  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlow.channel#3
2019-02-16 00:00:12.103  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#3,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#3,bean=anonymous]
2019-02-16 00:00:12.107  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlow.channel#3
2019-02-16 00:00:12.109  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#3,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlow.channel#3,bean=anonymous]
2019-02-16 00:00:12.113  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsReceiveFlow.channel#1
2019-02-16 00:00:12.115  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#1,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#1,bean=anonymous]
2019-02-16 00:00:12.119  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler errorLogger
2019-02-16 00:00:12.120  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=errorLogger,bean=internal': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=errorLogger,bean=internal]
2019-02-16 00:00:12.124  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler notFoundChannel
2019-02-16 00:00:12.126  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=notFoundChannel,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=notFoundChannel,bean=anonymous]
2019-02-16 00:00:12.129  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsReceiveToKafka.input
2019-02-16 00:00:12.131  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsReceiveToKafka.input,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsReceiveToKafka.input,bean=anonymous]
2019-02-16 00:00:12.135  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personReceiveFlow.channel#1
2019-02-16 00:00:12.137  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#1,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#1,bean=anonymous]
2019-02-16 00:00:12.142  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlowConfig.personReceiveFailure.serviceActivator
2019-02-16 00:00:12.146  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.personReceiveFailure.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.personReceiveFailure.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.152  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlowConfig.logDiscard.serviceActivator
2019-02-16 00:00:12.158  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.logDiscard.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.logDiscard.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.164  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personReceiveToKafka.input
2019-02-16 00:00:12.166  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personReceiveToKafka.input,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personReceiveToKafka.input,bean=anonymous]
2019-02-16 00:00:12.169  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlow.channel#0
2019-02-16 00:00:12.171  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.175  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personReceiveFlow.channel#2
2019-02-16 00:00:12.178  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#2,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#2,bean=anonymous]
2019-02-16 00:00:12.199  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlowConfig.goodsReceiveSuccess.serviceActivator
2019-02-16 00:00:12.203  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodsReceiveSuccess.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodsReceiveSuccess.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.212  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsReceiveFlow.channel#2
2019-02-16 00:00:12.214  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#2,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#2,bean=anonymous]
2019-02-16 00:00:12.218  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personReceiveFlow.channel#0
2019-02-16 00:00:12.220  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.223  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlowConfig.personReceiveSuccess.serviceActivator
2019-02-16 00:00:12.225  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.personReceiveSuccess.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.personReceiveSuccess.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.229  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsIntegrationFlowConfig.goodslogDiscard.serviceActivator
2019-02-16 00:00:12.230  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodslogDiscard.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsIntegrationFlowConfig.goodslogDiscard.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.234  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler goodsReceiveFlow.channel#0
2019-02-16 00:00:12.236  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=goodsReceiveFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.239  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlow.channel#2
2019-02-16 00:00:12.241  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#2,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlow.channel#2,bean=anonymous]
2019-02-16 00:00:12.244  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler toOccPerson.input
2019-02-16 00:00:12.246  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=toOccPerson.input,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=toOccPerson.input,bean=anonymous]
2019-02-16 00:00:12.250  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personIntegrationFlowConfig.logException.serviceActivator
2019-02-16 00:00:12.251  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.logException.serviceActivator,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personIntegrationFlowConfig.logException.serviceActivator,bean=endpoint]
2019-02-16 00:00:12.255  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler personReceiveFlow.channel#3
2019-02-16 00:00:12.256  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#3,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageHandler,name=personReceiveFlow.channel#3,bean=anonymous]
2019-02-16 00:00:12.261  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageSource personReceiveFlow.channel#0
2019-02-16 00:00:12.262  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageSource,name=personReceiveFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageSource,name=personReceiveFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.270  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageSource goodsReceiveFlow.channel#0
2019-02-16 00:00:12.272  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=MessageSource,name=goodsReceiveFlow.channel#0,bean=anonymous': registering with JMX server as MBean [org.springframework.integration:type=MessageSource,name=goodsReceiveFlow.channel#0,bean=anonymous]
2019-02-16 00:00:12.274  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$GoodsOutboundGateway,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$GoodsOutboundGateway,bean=endpoint]
2019-02-16 00:00:12.276  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$GoodsOutboundGateway,bean=endpoint
2019-02-16 00:00:12.276  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$ToOccGoodsGateway,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$ToOccGoodsGateway,bean=endpoint]
2019-02-16 00:00:12.277  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=goodsIntegrationFlowConfig$ToOccGoodsGateway,bean=endpoint
2019-02-16 00:00:12.277  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$PersonOutboundGateway,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$PersonOutboundGateway,bean=endpoint]
2019-02-16 00:00:12.278  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$PersonOutboundGateway,bean=endpoint
2019-02-16 00:00:12.278  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$ToOccPersonGateway,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$ToOccPersonGateway,bean=endpoint]
2019-02-16 00:00:12.278  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=personIntegrationFlowConfig$ToOccPersonGateway,bean=endpoint
2019-02-16 00:00:12.279  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#2,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#2,bean=endpoint]
2019-02-16 00:00:12.279  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#2,bean=endpoint
2019-02-16 00:00:12.279  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#8,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#8,bean=endpoint]
2019-02-16 00:00:12.280  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#8,bean=endpoint
2019-02-16 00:00:12.280  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#0,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#0,bean=endpoint]
2019-02-16 00:00:12.281  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#0,bean=endpoint
2019-02-16 00:00:12.281  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#13,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#13,bean=endpoint]
2019-02-16 00:00:12.282  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#13,bean=endpoint
2019-02-16 00:00:12.284  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#14,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#14,bean=endpoint]
2019-02-16 00:00:12.287  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#14,bean=endpoint
2019-02-16 00:00:12.287  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#20,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#20,bean=endpoint]
2019-02-16 00:00:12.288  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#20,bean=endpoint
2019-02-16 00:00:12.289  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#1,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#1,bean=endpoint]
2019-02-16 00:00:12.289  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#1,bean=endpoint
2019-02-16 00:00:12.290  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Located managed bean 'org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#25,bean=endpoint': registering with JMX server as MBean [org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#25,bean=endpoint]
2019-02-16 00:00:12.291  INFO 4326 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registered endpoint without MessageSource: org.springframework.integration:type=ManagedEndpoint,name=org.springframework.integration.config.ConsumerEndpointFactoryBean#25,bean=endpoint
2019-02-16 00:00:12.316  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase -2147483648
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:goodsIntegrationFlowConfig.goodsReceiveFailure.serviceActivator} as a subscriber to the 'goods-failure-channel' channel
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goods-failure-channel' has 1 subscriber(s).
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started goodsIntegrationFlowConfig.goodsReceiveFailure.serviceActivator
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:goodsIntegrationFlowConfig.goodsReceiveSuccess.serviceActivator} as a subscriber to the 'goods-success-channel' channel
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goods-success-channel' has 1 subscriber(s).
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started goodsIntegrationFlowConfig.goodsReceiveSuccess.serviceActivator
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:goodsIntegrationFlowConfig.goodslogDiscard.serviceActivator} as a subscriber to the 'goods-invalid-channel' channel
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goods-invalid-channel' has 1 subscriber(s).
2019-02-16 00:00:12.317  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started goodsIntegrationFlowConfig.goodslogDiscard.serviceActivator
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:goodsIntegrationFlowConfig.goodslogException.serviceActivator} as a subscriber to the 'goods-exception-channel' channel
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goods-exception-channel' has 1 subscriber(s).
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started goodsIntegrationFlowConfig.goodslogException.serviceActivator
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:personIntegrationFlowConfig.personReceiveFailure.serviceActivator} as a subscriber to the 'person-failure-channel' channel
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.person-failure-channel' has 1 subscriber(s).
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started personIntegrationFlowConfig.personReceiveFailure.serviceActivator
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:personIntegrationFlowConfig.personReceiveSuccess.serviceActivator} as a subscriber to the 'person-success-channel' channel
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.person-success-channel' has 1 subscriber(s).
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started personIntegrationFlowConfig.personReceiveSuccess.serviceActivator
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:personIntegrationFlowConfig.logDiscard.serviceActivator} as a subscriber to the 'person-invalid-channel' channel
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.person-invalid-channel' has 1 subscriber(s).
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started personIntegrationFlowConfig.logDiscard.serviceActivator
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {message-handler:personIntegrationFlowConfig.logException.serviceActivator} as a subscriber to the 'person-exception-channel' channel
2019-02-16 00:00:12.318  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.person-exception-channel' has 1 subscriber(s).
2019-02-16 00:00:12.319  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started personIntegrationFlowConfig.logException.serviceActivator
2019-02-16 00:00:12.319  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase -2147482648
2019-02-16 00:00:12.451  INFO 4326 --- [           main] c.y.occ.MyIntegrationApplication      : No active profile set, falling back to default profiles: default
2019-02-16 00:00:12.455  INFO 4326 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@31a4db4f: startup date [Sat Feb 16 00:00:12 CST 2019]; parent: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@55787112
2019-02-16 00:00:12.482  INFO 4326 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-02-16 00:00:12.546  INFO 4326 --- [           main] o.s.c.s.b.k.c.KafkaBinderConfiguration   : AdminUtils selected: Kafka 0.10 AdminUtils
2019-02-16 00:00:12.601  INFO 4326 --- [           main] c.y.occ.MyIntegrationApplication      : Started MyIntegrationApplication in 0.27 seconds (JVM running for 16.087)
2019-02-16 00:00:12.634  INFO 4326 --- [           main] o.s.c.s.b.k.p.KafkaTopicProvisioner      : Using kafka topic for outbound: output-to-occ-goodsdouhe
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:host.name=kimcheungs-mbp
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.version=1.8.0_162
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.vendor=Oracle Corporation
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.class.path=/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/tools.jar:/Users/Princelo/Practice/demo2/target/classes:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-web/1.5.10.RELEASE/spring-boot-starter-web-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter/1.5.10.RELEASE/spring-boot-starter-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot/1.5.10.RELEASE/spring-boot-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-autoconfigure/1.5.10.RELEASE/spring-boot-autoconfigure-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-logging/1.5.10.RELEASE/spring-boot-starter-logging-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/ch/qos/logback/logback-classic/1.1.11/logback-classic-1.1.11.jar:/Users/Princelo/.m2/mycorp_repository/ch/qos/logback/logback-core/1.1.11/logback-core-1.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25.jar:/Users/Princelo/.m2/mycorp_repository/org/slf4j/log4j-over-slf4j/1.7.25/log4j-over-slf4j-1.7.25.jar:/Users/Princelo/.m2/mycorp_repository/org/yaml/snakeyaml/1.17/snakeyaml-1.17.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-tomcat/1.5.10.RELEASE/spring-boot-starter-tomcat-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/embed/tomcat-embed-core/8.5.27/tomcat-embed-core-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/tomcat-annotations-api/8.5.27/tomcat-annotations-api-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/embed/tomcat-embed-el/8.5.27/tomcat-embed-el-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/embed/tomcat-embed-websocket/8.5.27/tomcat-embed-websocket-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/hibernate/hibernate-validator/5.3.6.Final/hibernate-validator-5.3.6.Final.jar:/Users/Princelo/.m2/mycorp_repository/org/jboss/logging/jboss-logging/3.3.1.Final/jboss-logging-3.3.1.Final.jar:/Users/Princelo/.m2/mycorp_repository/com/fasterxml/classmate/1.3.4/classmate-1.3.4.jar:/Users/Princelo/.m2/mycorp_repository/com/fasterxml/jackson/core/jackson-databind/2.8.10/jackson-databind-2.8.10.jar:/Users/Princelo/.m2/mycorp_repository/com/fasterxml/jackson/core/jackson-annotations/2.8.0/jackson-annotations-2.8.0.jar:/Users/Princelo/.m2/mycorp_repository/com/fasterxml/jackson/core/jackson-core/2.8.10/jackson-core-2.8.10.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-web/4.3.14.RELEASE/spring-web-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-beans/4.3.14.RELEASE/spring-beans-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-webmvc/4.3.14.RELEASE/spring-webmvc-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-expression/4.3.14.RELEASE/spring-expression-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-integration/1.5.10.RELEASE/spring-boot-starter-integration-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-aop/1.5.10.RELEASE/spring-boot-starter-aop-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/aspectj/aspectjweaver/1.8.13/aspectjweaver-1.8.13.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-java-dsl/1.2.3.RELEASE/spring-integration-java-dsl-1.2.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/reactivestreams/reactive-streams/1.0.0/reactive-streams-1.0.0.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-core/4.3.14.RELEASE/spring-integration-core-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-core/4.3.14.RELEASE/spring-core-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-aop/4.3.14.RELEASE/spring-aop-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-context/4.3.14.RELEASE/spring-context-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-messaging/4.3.14.RELEASE/spring-messaging-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-tx/4.3.14.RELEASE/spring-tx-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/retry/spring-retry/1.2.2.RELEASE/spring-retry-1.2.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-kafka/2.1.2.RELEASE/spring-integration-kafka-2.1.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/kafka/spring-kafka/1.1.7.RELEASE/spring-kafka-1.1.7.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/kafka/kafka-clients/0.10.1.1/kafka-clients-0.10.1.1.jar:/Users/Princelo/.m2/mycorp_repository/net/jpountz/lz4/lz4/1.3.0/lz4-1.3.0.jar:/Users/Princelo/.m2/mycorp_repository/org/xerial/snappy/snappy-java/1.1.2.6/snappy-java-1.1.2.6.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-http/4.3.14.RELEASE/spring-integration-http-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/junit/junit/4.12/junit-4.12.jar:/Users/Princelo/.m2/mycorp_repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/Princelo/.m2/mycorp_repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/Princelo/.m2/mycorp_repository/org/projectlombok/lombok/1.16.20/lombok-1.16.20.jar:/Users/Princelo/.m2/mycorp_repository/com/github/java-json-tools/json-schema-validator/2.2.10/json-schema-validator-2.2.10.jar:/Users/Princelo/.m2/mycorp_repository/com/github/java-json-tools/json-schema-core/1.2.10/json-schema-core-1.2.10.jar:/Users/Princelo/.m2/mycorp_repository/com/github/java-json-tools/jackson-coreutils/1.9/jackson-coreutils-1.9.jar:/Users/Princelo/.m2/mycorp_repository/com/github/fge/msg-simple/1.1/msg-simple-1.1.jar:/Users/Princelo/.m2/mycorp_repository/com/github/fge/btf/1.2/btf-1.2.jar:/Users/Princelo/.m2/mycorp_repository/com/github/fge/uri-template/0.9/uri-template-0.9.jar:/Users/Princelo/.m2/mycorp_repository/org/mozilla/rhino/1.7.7.1/rhino-1.7.7.1.jar:/Users/Princelo/.m2/mycorp_repository/javax/mail/mailapi/1.4.3/mailapi-1.4.3.jar:/Users/Princelo/.m2/mycorp_repository/javax/activation/activation/1.1/activation-1.1.jar:/Users/Princelo/.m2/mycorp_repository/joda-time/joda-time/2.9.9/joda-time-2.9.9.jar:/Users/Princelo/.m2/mycorp_repository/com/googlecode/libphonenumber/libphonenumber/8.0.0/libphonenumber-8.0.0.jar:/Users/Princelo/.m2/mycorp_repository/com/google/code/findbugs/jsr305/3.0.1/jsr305-3.0.1.jar:/Users/Princelo/.m2/mycorp_repository/net/sf/jopt-simple/jopt-simple/5.0.3/jopt-simple-5.0.3.jar:/Users/Princelo/.m2/mycorp_repository/com/mycorp/occ/occ-base-api/1.0.0/occ-base-api-1.0.0.jar:/Users/Princelo/.m2/mycorp_repository/javax/validation/validation-api/1.1.0.Final/validation-api-1.1.0.Final.jar:/Users/Princelo/.m2/mycorp_repository/org/hibernate/javax/persistence/hibernate-jpa-2.1-api/1.0.2.Final/hibernate-jpa-2.1-api-1.0.2.Final.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/data/spring-data-commons/1.13.10.RELEASE/spring-data-commons-1.13.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/slf4j/jcl-over-slf4j/1.7.25/jcl-over-slf4j-1.7.25.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/commons/commons-lang3/3.7/commons-lang3-3.7.jar:/Users/Princelo/.m2/mycorp_repository/com/mycorp/occ/occ-integration-api/1.0.0/occ-integration-api-1.0.0.jar:/Users/Princelo/.m2/mycorp_repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar:/Users/Princelo/.m2/mycorp_repository/com/mycorp/occ/occ-settlement-api/1.0.0/occ-settlement-api-1.0.0.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-frontend-jaxws/3.1.13/cxf-rt-frontend-jaxws-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/xml-resolver/xml-resolver/1.2/xml-resolver-1.2.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-core/3.1.13/cxf-core-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/codehaus/woodstox/woodstox-core-asl/4.4.1/woodstox-core-asl-4.4.1.jar:/Users/Princelo/.m2/mycorp_repository/org/codehaus/woodstox/stax2-api/3.1.4/stax2-api-3.1.4.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/ws/xmlschema/xmlschema-core/2.2.2/xmlschema-core-2.2.2.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-bindings-soap/3.1.13/cxf-rt-bindings-soap-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-wsdl/3.1.13/cxf-rt-wsdl-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/wsdl4j/wsdl4j/1.6.3/wsdl4j-1.6.3.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-databinding-jaxb/3.1.13/cxf-rt-databinding-jaxb-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/com/sun/xml/bind/jaxb-impl/2.2.11/jaxb-impl-2.2.11.jar:/Users/Princelo/.m2/mycorp_repository/com/sun/xml/bind/jaxb-core/2.2.11/jaxb-core-2.2.11.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-bindings-xml/3.1.13/cxf-rt-bindings-xml-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-frontend-simple/3.1.13/cxf-rt-frontend-simple-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-ws-addr/3.1.13/cxf-rt-ws-addr-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-ws-policy/3.1.13/cxf-rt-ws-policy-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-transports-http/3.1.13/cxf-rt-transports-http-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-ws-security/3.1.13/cxf-rt-ws-security-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-security-saml/3.1.13/cxf-rt-security-saml-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/cxf/cxf-rt-security/3.1.13/cxf-rt-security-3.1.13.jar:/Users/Princelo/.m2/mycorp_repository/net/sf/ehcache/ehcache/2.10.4/ehcache-2.10.4.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-ws-security-dom/2.1.11/wss4j-ws-security-dom-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-ws-security-common/2.1.11/wss4j-ws-security-common-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-saml-impl/3.1.1/opensaml-saml-impl-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-profile-api/3.1.1/opensaml-profile-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-core/3.1.1/opensaml-core-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-saml-api/3.1.1/opensaml-saml-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xmlsec-api/3.1.1/opensaml-xmlsec-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-soap-api/3.1.1/opensaml-soap-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-security-impl/3.1.1/opensaml-security-impl-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-security-api/3.1.1/opensaml-security-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/cryptacular/cryptacular/1.0/cryptacular-1.0.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xmlsec-impl/3.1.1/opensaml-xmlsec-impl-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/net/shibboleth/utilities/java-support/7.1.1/java-support-7.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xacml-impl/3.1.1/opensaml-xacml-impl-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xacml-api/3.1.1/opensaml-xacml-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xacml-saml-impl/3.1.1/opensaml-xacml-saml-impl-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/opensaml/opensaml-xacml-saml-api/3.1.1/opensaml-xacml-saml-api-3.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/jasypt/jasypt/1.9.2/jasypt-1.9.2.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/geronimo/specs/geronimo-javamail_1.4_spec/1.7.1/geronimo-javamail_1.4_spec-1.7.1.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-policy/2.1.11/wss4j-policy-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/neethi/neethi/3.1.0/neethi-3.1.0.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-ws-security-stax/2.1.11/wss4j-ws-security-stax-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-bindings/2.1.11/wss4j-bindings-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/wss4j/wss4j-ws-security-policy-stax/2.1.11/wss4j-ws-security-policy-stax-2.1.11.jar:/Users/Princelo/.m2/mycorp_repository/com/mycorp/occ/occ-common/1.0.0/occ-common-1.0.0.jar:/Users/Princelo/.m2/mycorp_repository/com/google/code/gson/gson/2.8.2/gson-2.8.2.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-actuator/1.5.10.RELEASE/spring-boot-starter-actuator-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-actuator/1.5.10.RELEASE/spring-boot-actuator-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-stream-kafka/1.3.2.RELEASE/spring-cloud-starter-stream-kafka-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-stream-binder-kafka/1.3.2.RELEASE/spring-cloud-stream-binder-kafka-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-stream-binder-kafka-core/1.3.2.RELEASE/spring-cloud-stream-binder-kafka-core-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-stream/1.3.2.RELEASE/spring-cloud-stream-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-validation/1.5.10.RELEASE/spring-boot-starter-validation-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-jmx/4.3.14.RELEASE/spring-integration-jmx-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-tuple/1.0.0.RELEASE/spring-tuple-1.0.0.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/integration/spring-integration-tuple/1.0.0.RELEASE/spring-integration-tuple-1.0.0.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-stream-codec/1.3.2.RELEASE/spring-cloud-stream-codec-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/com/esotericsoftware/kryo-shaded/3.0.3/kryo-shaded-3.0.3.jar:/Users/Princelo/.m2/mycorp_repository/com/esotericsoftware/minlog/1.3.0/minlog-1.3.0.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/kafka/kafka_2.11/0.10.1.1/kafka_2.11-0.10.1.1.jar:/Users/Princelo/.m2/mycorp_repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/Users/Princelo/.m2/mycorp_repository/org/scala-lang/scala-library/2.11.8/scala-library-2.11.8.jar:/Users/Princelo/.m2/mycorp_repository/com/101tec/zkclient/0.9/zkclient-0.9.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/zookeeper/zookeeper/3.4.8/zookeeper-3.4.8.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/Users/Princelo/.m2/mycorp_repository/org/scala-lang/modules/scala-parser-combinators_2.11/1.0.4/scala-parser-combinators_2.11-1.0.4.jar:/Users/Princelo/.m2/mycorp_repository/de/codecentric/spring-boot-admin-starter-client/1.5.6/spring-boot-admin-starter-client-1.5.6.jar:/Users/Princelo/.m2/mycorp_repository/org/jolokia/jolokia-core/1.3.7/jolokia-core-1.3.7.jar:/Users/Princelo/.m2/mycorp_repository/com/googlecode/json-simple/json-simple/1.1.1/json-simple-1.1.1.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-eureka/1.4.3.RELEASE/spring-cloud-starter-eureka-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-netflix-eureka-client/1.4.3.RELEASE/spring-cloud-starter-netflix-eureka-client-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-netflix-eureka-client/1.4.3.RELEASE/spring-cloud-netflix-eureka-client-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/eureka/eureka-client/1.7.0/eureka-client-1.7.0.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/netflix-commons/netflix-eventbus/0.3.0/netflix-eventbus-0.3.0.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/netflix-commons/netflix-infix/0.3.0/netflix-infix-0.3.0.jar:/Users/Princelo/.m2/mycorp_repository/commons-jxpath/commons-jxpath/1.3/commons-jxpath-1.3.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/Users/Princelo/.m2/mycorp_repository/javax/ws/rs/jsr311-api/1.1.1/jsr311-api-1.1.1.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/servo/servo-core/0.10.1/servo-core-0.10.1.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/servo/servo-internal/0.10.1/servo-internal-0.10.1.jar:/Users/Princelo/.m2/mycorp_repository/com/sun/jersey/jersey-core/1.19.1/jersey-core-1.19.1.jar:/Users/Princelo/.m2/mycorp_repository/com/sun/jersey/jersey-client/1.19.1/jersey-client-1.19.1.jar:/Users/Princelo/.m2/mycorp_repository/com/sun/jersey/contribs/jersey-apache-client4/1.19.1/jersey-apache-client4-1.19.1.jar:/Users/Princelo/.m2/mycorp_repository/com/google/inject/guice/4.1.0/guice-4.1.0.jar:/Users/Princelo/.m2/mycorp_repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/eureka/eureka-core/1.7.0/eureka-core-1.7.0.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon-eureka/2.2.4/ribbon-eureka-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/com/thoughtworks/xstream/xstream/1.4.9/xstream-1.4.9.jar:/Users/Princelo/.m2/mycorp_repository/xmlpull/xmlpull/1.1.3.1/xmlpull-1.1.3.1.jar:/Users/Princelo/.m2/mycorp_repository/xpp3/xpp3_min/1.1.4c/xpp3_min-1.1.4c.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-jdbc/1.5.10.RELEASE/spring-boot-starter-jdbc-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/tomcat-jdbc/8.5.27/tomcat-jdbc-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/tomcat/tomcat-juli/8.5.27/tomcat-juli-8.5.27.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/spring-jdbc/4.3.14.RELEASE/spring-jdbc-4.3.14.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-starter-security/1.5.10.RELEASE/spring-boot-starter-security-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/security/spring-security-config/4.2.4.RELEASE/spring-security-config-4.2.4.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/security/spring-security-core/4.2.4.RELEASE/spring-security-core-4.2.4.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/security/spring-security-web/4.2.4.RELEASE/spring-security-web-4.2.4.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/boot/spring-boot-configuration-processor/1.5.10.RELEASE/spring-boot-configuration-processor-1.5.10.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/com/oracle/ojdbc6/11.1.0.7.0/ojdbc6-11.1.0.7.0.jar:/Users/Princelo/.m2/mycorp_repository/com/alibaba/druid/1.0.18/druid-1.0.18.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-openfeign/1.4.3.RELEASE/spring-cloud-starter-openfeign-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter/1.3.2.RELEASE/spring-cloud-starter-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-context/1.3.2.RELEASE/spring-cloud-context-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/security/spring-security-rsa/1.0.3.RELEASE/spring-security-rsa-1.0.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/bouncycastle/bcpkix-jdk15on/1.55/bcpkix-jdk15on-1.55.jar:/Users/Princelo/.m2/mycorp_repository/org/bouncycastle/bcprov-jdk15on/1.55/bcprov-jdk15on-1.55.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-netflix-core/1.4.3.RELEASE/spring-cloud-netflix-core-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-commons/1.3.2.RELEASE/spring-cloud-commons-1.3.2.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/security/spring-security-crypto/4.2.4.RELEASE/spring-security-crypto-4.2.4.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/httpcomponents/httpclient/4.5.5/httpclient-4.5.5.jar:/Users/Princelo/.m2/mycorp_repository/org/apache/httpcomponents/httpcore/4.4.9/httpcore-4.4.9.jar:/Users/Princelo/.m2/mycorp_repository/commons-codec/commons-codec/1.10/commons-codec-1.10.jar:/Users/Princelo/.m2/mycorp_repository/io/github/openfeign/feign-core/9.5.0/feign-core-9.5.0.jar:/Users/Princelo/.m2/mycorp_repository/org/jvnet/animal-sniffer-annotation/1.0/animal-sniffer-annotation-1.0.jar:/Users/Princelo/.m2/mycorp_repository/io/github/openfeign/feign-slf4j/9.5.0/feign-slf4j-9.5.0.jar:/Users/Princelo/.m2/mycorp_repository/io/github/openfeign/feign-hystrix/9.5.0/feign-hystrix-9.5.0.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/archaius/archaius-core/0.7.4/archaius-core-0.7.4.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/hystrix/hystrix-core/1.5.12/hystrix-core-1.5.12.jar:/Users/Princelo/.m2/mycorp_repository/org/hdrhistogram/HdrHistogram/2.1.9/HdrHistogram-2.1.9.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-netflix-ribbon/1.4.3.RELEASE/spring-cloud-starter-netflix-ribbon-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon/2.2.4/ribbon-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon-transport/2.2.4/ribbon-transport-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/io/reactivex/rxnetty-contexts/0.4.9/rxnetty-contexts-0.4.9.jar:/Users/Princelo/.m2/mycorp_repository/io/reactivex/rxnetty-servo/0.4.9/rxnetty-servo-0.4.9.jar:/Users/Princelo/.m2/mycorp_repository/javax/inject/javax.inject/1/javax.inject-1.jar:/Users/Princelo/.m2/mycorp_repository/io/reactivex/rxnetty/0.4.9/rxnetty-0.4.9.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-codec-http/4.0.27.Final/netty-codec-http-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-codec/4.0.27.Final/netty-codec-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-handler/4.0.27.Final/netty-handler-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-transport-native-epoll/4.0.27.Final/netty-transport-native-epoll-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-common/4.0.27.Final/netty-common-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-buffer/4.0.27.Final/netty-buffer-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/io/netty/netty-transport/4.0.27.Final/netty-transport-4.0.27.Final.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon-core/2.2.4/ribbon-core-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon-httpclient/2.2.4/ribbon-httpclient-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/netflix-commons/netflix-commons-util/0.1.1/netflix-commons-util-0.1.1.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/ribbon/ribbon-loadbalancer/2.2.4/ribbon-loadbalancer-2.2.4.jar:/Users/Princelo/.m2/mycorp_repository/com/netflix/netflix-commons/netflix-statistics/0.1.1/netflix-statistics-0.1.1.jar:/Users/Princelo/.m2/mycorp_repository/io/reactivex/rxjava/1.2.0/rxjava-1.2.0.jar:/Users/Princelo/.m2/mycorp_repository/org/springframework/cloud/spring-cloud-starter-netflix-archaius/1.4.3.RELEASE/spring-cloud-starter-netflix-archaius-1.4.3.RELEASE.jar:/Users/Princelo/.m2/mycorp_repository/commons-configuration/commons-configuration/1.8/commons-configuration-1.8.jar:/Users/Princelo/.m2/mycorp_repository/com/google/guava/guava/18.0/guava-18.0.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.library.path=/Users/Princelo/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:.
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.io.tmpdir=/var/folders/fb/l3m8vcns48lc_5cdjx2nt5wc0000gn/T/
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:java.compiler=<NA>
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:os.name=Mac OS X
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:os.arch=x86_64
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:os.version=10.14.3
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:user.name=Princelo
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:user.home=/Users/Princelo
2019-02-16 00:00:12.644  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Client environment:user.dir=/Users/Princelo/Practice/goods-sync
2019-02-16 00:00:12.645  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@2ce62e27
2019-02-16 00:00:12.659  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2019-02-16 00:00:12.713  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
2019-02-16 00:00:12.722  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x168f1d8d5c20009, negotiated timeout = 10000
2019-02-16 00:00:13.050  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Session: 0x168f1d8d5c20009 closed
2019-02-16 00:00:13.050  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@18c26588
2019-02-16 00:00:13.051  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2019-02-16 00:00:13.050  INFO 4326 --- [ain-EventThread] org.apache.zookeeper.ClientCnxn          : EventThread shut down for session: 0x168f1d8d5c20009
2019-02-16 00:00:13.052  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
2019-02-16 00:00:13.053  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x168f1d8d5c2000a, negotiated timeout = 10000
2019-02-16 00:00:13.066  INFO 4326 --- [           main] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
    acks = 1
    batch.size = 16384
    block.on.buffer.full = false
    bootstrap.servers = [127.0.0.1:9092]
    buffer.memory = 33554432
    client.id = 
    compression.type = none
    connections.max.idle.ms = 540000
    interceptor.classes = null
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 5
    max.request.size = 1048576
    metadata.fetch.timeout.ms = 60000
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.ms = 50
    request.timeout.ms = 30000
    retries = 0
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    timeout.ms = 30000
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer

2019-02-16 00:00:13.070  INFO 4326 --- [           main] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
    acks = 1
    batch.size = 16384
    block.on.buffer.full = false
    bootstrap.servers = [127.0.0.1:9092]
    buffer.memory = 33554432
    client.id = producer-1
    compression.type = none
    connections.max.idle.ms = 540000
    interceptor.classes = null
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 5
    max.request.size = 1048576
    metadata.fetch.timeout.ms = 60000
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.ms = 50
    request.timeout.ms = 30000
    retries = 0
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    timeout.ms = 30000
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer

2019-02-16 00:00:13.091  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2019-02-16 00:00:13.091  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
2019-02-16 00:00:13.205  INFO 4326 --- [           main] o.a.k.clients.producer.KafkaProducer     : Closing the Kafka producer with timeoutMillis = 30000 ms.
2019-02-16 00:00:13.209  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.output-to-occ-goodsdouhe' has 1 subscriber(s).
2019-02-16 00:00:13.210  INFO 4326 --- [           main] o.s.c.s.b.k.p.KafkaTopicProvisioner      : Using kafka topic for outbound: to-occ-person
2019-02-16 00:00:13.211  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@4b518645
2019-02-16 00:00:13.211  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2019-02-16 00:00:13.211  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
2019-02-16 00:00:13.213  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x168f1d8d5c2000b, negotiated timeout = 10000
2019-02-16 00:00:13.242  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Session: 0x168f1d8d5c2000b closed
2019-02-16 00:00:13.242  INFO 4326 --- [ain-EventThread] org.apache.zookeeper.ClientCnxn          : EventThread shut down for session: 0x168f1d8d5c2000b
2019-02-16 00:00:13.243  INFO 4326 --- [           main] org.apache.zookeeper.ZooKeeper           : Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@294a3f2a
2019-02-16 00:00:13.243  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2019-02-16 00:00:13.244  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
2019-02-16 00:00:13.245  INFO 4326 --- [127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn          : Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x168f1d8d5c2000c, negotiated timeout = 10000
2019-02-16 00:00:13.255  INFO 4326 --- [           main] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
    acks = 1
    batch.size = 16384
    block.on.buffer.full = false
    bootstrap.servers = [127.0.0.1:9092]
    buffer.memory = 33554432
    client.id = 
    compression.type = none
    connections.max.idle.ms = 540000
    interceptor.classes = null
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 5
    max.request.size = 1048576
    metadata.fetch.timeout.ms = 60000
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.ms = 50
    request.timeout.ms = 30000
    retries = 0
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    timeout.ms = 30000
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer

2019-02-16 00:00:13.255  INFO 4326 --- [           main] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
    acks = 1
    batch.size = 16384
    block.on.buffer.full = false
    bootstrap.servers = [127.0.0.1:9092]
    buffer.memory = 33554432
    client.id = producer-2
    compression.type = none
    connections.max.idle.ms = 540000
    interceptor.classes = null
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 5
    max.request.size = 1048576
    metadata.fetch.timeout.ms = 60000
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.ms = 50
    request.timeout.ms = 30000
    retries = 0
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    timeout.ms = 30000
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer

2019-02-16 00:00:13.257  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2019-02-16 00:00:13.257  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
2019-02-16 00:00:13.463  INFO 4326 --- [           main] o.a.k.clients.producer.KafkaProducer     : Closing the Kafka producer with timeoutMillis = 30000 ms.
2019-02-16 00:00:13.465  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.output-to-occ-person' has 1 subscriber(s).
2019-02-16 00:00:13.466  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 0
2019-02-16 00:00:13.482  INFO 4326 --- [           main] o.s.c.n.eureka.InstanceInfoFactory       : Setting initial instance status as: STARTING
2019-02-16 00:00:13.521  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Initializing Eureka in region us-east-1
2019-02-16 00:00:13.737  INFO 4326 --- [           main] c.n.d.provider.DiscoveryJerseyProvider   : Using JSON encoding codec LegacyJacksonJson
2019-02-16 00:00:13.737  INFO 4326 --- [           main] c.n.d.provider.DiscoveryJerseyProvider   : Using JSON decoding codec LegacyJacksonJson
2019-02-16 00:00:13.829  INFO 4326 --- [           main] c.n.d.provider.DiscoveryJerseyProvider   : Using XML encoding codec XStreamXml
2019-02-16 00:00:13.829  INFO 4326 --- [           main] c.n.d.provider.DiscoveryJerseyProvider   : Using XML decoding codec XStreamXml
2019-02-16 00:00:14.034  INFO 4326 --- [           main] c.n.d.s.r.aws.ConfigClusterResolver      : Resolving eureka endpoints via configuration
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Disable delta property : false
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Single vip registry refresh property : null
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Force full registry fetch : false
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Application is null : false
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Registered Applications size is zero : true
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Application version is -1: true
2019-02-16 00:00:14.049  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Getting all instance registry info from the eureka server
2019-02-16 00:00:14.479  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : The response status is 200
2019-02-16 00:00:14.480  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Starting heartbeat executor: renew interval is: 30
2019-02-16 00:00:14.483  INFO 4326 --- [           main] c.n.discovery.InstanceInfoReplicator     : InstanceInfoReplicator onDemand update allowed rate per min is 4
2019-02-16 00:00:14.485  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Discovery Client initialized at timestamp 1550246414485 with initial instances count: 1
2019-02-16 00:00:14.496  INFO 4326 --- [           main] o.s.c.n.e.s.EurekaServiceRegistry        : Registering application Myintegration with eureka with status UP
2019-02-16 00:00:14.497  INFO 4326 --- [           main] com.netflix.discovery.DiscoveryClient    : Saw local status change event StatusChangeEvent [timestamp=1550246414497, current=UP, previous=STARTING]
2019-02-16 00:00:14.498  INFO 4326 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_MyINTEGRATION/192.168.43.66:8066: registering service...
2019-02-16 00:00:14.498  INFO 4326 --- [           main] ProxyFactoryBean$MethodInvocationGateway : started goodsIntegrationFlowConfig$GoodsOutboundGateway
2019-02-16 00:00:14.498  INFO 4326 --- [           main] GatewayCompletableFutureProxyFactoryBean : started goodsIntegrationFlowConfig$GoodsOutboundGateway
2019-02-16 00:00:14.498  INFO 4326 --- [           main] ProxyFactoryBean$MethodInvocationGateway : started goodsIntegrationFlowConfig$ToOccGoodsGateway
2019-02-16 00:00:14.498  INFO 4326 --- [           main] GatewayCompletableFutureProxyFactoryBean : started goodsIntegrationFlowConfig$ToOccGoodsGateway
2019-02-16 00:00:14.499  INFO 4326 --- [           main] ProxyFactoryBean$MethodInvocationGateway : started personIntegrationFlowConfig$PersonOutboundGateway
2019-02-16 00:00:14.499  INFO 4326 --- [           main] GatewayCompletableFutureProxyFactoryBean : started personIntegrationFlowConfig$PersonOutboundGateway
2019-02-16 00:00:14.499  INFO 4326 --- [           main] ProxyFactoryBean$MethodInvocationGateway : started personIntegrationFlowConfig$ToOccPersonGateway
2019-02-16 00:00:14.499  INFO 4326 --- [           main] GatewayCompletableFutureProxyFactoryBean : started personIntegrationFlowConfig$ToOccPersonGateway
2019-02-16 00:00:14.529  INFO 4326 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_MyINTEGRATION/192.168.43.66:8066 - registration status: 204
2019-02-16 00:00:14.562  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2019-02-16 00:00:14.562  INFO 4326 --- [           main] o.s.i.channel.PublishSubscribeChannel    : Channel 'Myintegration:8066.errorChannel' has 1 subscriber(s).
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started _org.springframework.integration.errorLogger
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'notFoundChannel' channel
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.notFoundChannel' has 1 subscriber(s).
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#0
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'badRequestChannel' channel
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.badRequestChannel' has 1 subscriber(s).
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#1
2019-02-16 00:00:14.563  INFO 4326 --- [           main] .h.i.HttpRequestHandlingMessagingGateway : started org.springframework.integration.http.inbound.HttpRequestHandlingMessagingGateway#0
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'goodsReceiveFlow.channel#0' channel
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsReceiveFlow.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#2
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'goodsReceiveFlow.channel#1' channel
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsReceiveFlow.channel#1' has 1 subscriber(s).
2019-02-16 00:00:14.563  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#3
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {service-activator} as a subscriber to the 'goodsReceiveFlow.channel#2' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsReceiveFlow.channel#2' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#4
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {service-activator} as a subscriber to the 'goodsReceiveFlow.channel#3' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsReceiveFlow.channel#3' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#5
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {kafka:outbound-channel-adapter} as a subscriber to the 'goodsReceiveToKafka.input' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsReceiveToKafka.input' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#6
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'toOccGoods.input' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.toOccGoods.input' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#7
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.toOccGoods.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#8
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'goodsIntegrationFlow.channel#0' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsIntegrationFlow.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#9
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'goodsIntegrationFlow.channel#1' channel
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsIntegrationFlow.channel#1' has 1 subscriber(s).
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#10
2019-02-16 00:00:14.564  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'goodsIntegrationFlow.channel#2' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsIntegrationFlow.channel#2' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#11
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'goodsIntegrationFlow.channel#3' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsIntegrationFlow.channel#3' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#12
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.goodsIntegrationFlow.channel#4' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#13
2019-02-16 00:00:14.565  INFO 4326 --- [           main] .h.i.HttpRequestHandlingMessagingGateway : started org.springframework.integration.http.inbound.HttpRequestHandlingMessagingGateway#1
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'personReceiveFlow.channel#0' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personReceiveFlow.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#14
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'personReceiveFlow.channel#1' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personReceiveFlow.channel#1' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#15
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {service-activator} as a subscriber to the 'personReceiveFlow.channel#2' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personReceiveFlow.channel#2' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#16
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {service-activator} as a subscriber to the 'personReceiveFlow.channel#3' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personReceiveFlow.channel#3' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#17
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {kafka:outbound-channel-adapter} as a subscriber to the 'personReceiveToKafka.input' channel
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personReceiveToKafka.input' has 1 subscriber(s).
2019-02-16 00:00:14.565  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#18
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'toOccPerson.input' channel
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.toOccPerson.input' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#19
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.toOccPerson.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#20
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'personIntegrationFlow.channel#0' channel
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personIntegrationFlow.channel#0' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#21
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'personIntegrationFlow.channel#1' channel
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personIntegrationFlow.channel#1' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#22
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {filter} as a subscriber to the 'personIntegrationFlow.channel#2' channel
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personIntegrationFlow.channel#2' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#23
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {transformer} as a subscriber to the 'personIntegrationFlow.channel#3' channel
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personIntegrationFlow.channel#3' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#24
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'Myintegration:8066.personIntegrationFlow.channel#4' has 1 subscriber(s).
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started org.springframework.integration.config.ConsumerEndpointFactoryBean#25
2019-02-16 00:00:14.566  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 1073741823
2019-02-16 00:00:14.571  INFO 4326 --- [           main] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = 
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:00:14.572  INFO 4326 --- [           main] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = consumer-1
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:00:14.581  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2019-02-16 00:00:14.582  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
2019-02-16 00:00:14.583  INFO 4326 --- [           main] s.i.k.i.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#0
2019-02-16 00:00:14.584  INFO 4326 --- [           main] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = 
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:00:14.584  INFO 4326 --- [           main] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = consumer-2
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:00:14.586  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2019-02-16 00:00:14.586  INFO 4326 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
2019-02-16 00:00:14.586  INFO 4326 --- [           main] s.i.k.i.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter#1
2019-02-16 00:00:14.586  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 2147482647
2019-02-16 00:00:14.586  INFO 4326 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 2147483647
2019-02-16 00:00:14.631  INFO 4326 --- [           main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8066 (http)
2019-02-16 00:00:14.632  INFO 4326 --- [           main] .s.c.n.e.s.EurekaAutoServiceRegistration : Updating port to 8066
2019-02-16 00:00:14.636  INFO 4326 --- [           main] c.y.occ.MyIntegrationApplication      : Started MyIntegrationApplication in 15.003 seconds (JVM running for 18.121)
2019-02-16 00:00:14.695  INFO 4326 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : Discovered coordinator 127.0.0.1:9092 (id: 2147483647 rack: null) for group MyintegrationGroup.
2019-02-16 00:00:14.700  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : Discovered coordinator 127.0.0.1:9092 (id: 2147483647 rack: null) for group MyintegrationGroup.
2019-02-16 00:00:14.702  INFO 4326 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : Revoking previously assigned partitions [] for group MyintegrationGroup
2019-02-16 00:00:14.702  INFO 4326 --- [ntainer#1-0-C-1] s.k.l.ConcurrentMessageListenerContainer : partitions revoked:[]
2019-02-16 00:00:14.703  INFO 4326 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : (Re-)joining group MyintegrationGroup
2019-02-16 00:00:14.706  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : Revoking previously assigned partitions [] for group MyintegrationGroup
2019-02-16 00:00:14.706  INFO 4326 --- [ntainer#0-0-C-1] s.k.l.ConcurrentMessageListenerContainer : partitions revoked:[]
2019-02-16 00:00:14.706  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : (Re-)joining group MyintegrationGroup
2019-02-16 00:00:14.720  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : (Re-)joining group MyintegrationGroup
2019-02-16 00:00:14.904  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : Successfully joined group MyintegrationGroup with generation 8
2019-02-16 00:00:14.904  INFO 4326 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : Successfully joined group MyintegrationGroup with generation 8
2019-02-16 00:00:14.906  INFO 4326 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : Setting newly assigned partitions [person-integration-0] for group MyintegrationGroup
2019-02-16 00:00:14.906  INFO 4326 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : Setting newly assigned partitions [goods-integration-0] for group MyintegrationGroup
2019-02-16 00:00:14.929  INFO 4326 --- [ntainer#0-0-C-1] s.k.l.ConcurrentMessageListenerContainer : partitions assigned:[goods-integration-0]
2019-02-16 00:00:14.930  INFO 4326 --- [ntainer#1-0-C-1] s.k.l.ConcurrentMessageListenerContainer : partitions assigned:[person-integration-0]
2019-02-16 00:00:21.296  INFO 4326 --- [nio-8066-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring FrameworkServlet 'dispatcherServlet'
2019-02-16 00:00:21.297  INFO 4326 --- [nio-8066-exec-1] o.s.web.servlet.DispatcherServlet        : FrameworkServlet 'dispatcherServlet': initialization started
2019-02-16 00:00:21.318  INFO 4326 --- [nio-8066-exec-1] o.s.web.servlet.DispatcherServlet        : FrameworkServlet 'dispatcherServlet': initialization completed in 21 ms
2019-02-16 00:01:15.885  INFO 4326 --- [on(4)-127.0.0.1] com.alibaba.druid.pool.DruidDataSource   : {dataSource-1} inited
2019-02-16 00:01:15.891  INFO 4326 --- [pool-9-thread-1] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = 
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:01:15.891  INFO 4326 --- [pool-9-thread-1] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [127.0.0.1:9092]
    check.crcs = true
    client.id = consumer-3
    connections.max.idle.ms = 540000
    enable.auto.commit = false
    exclude.internal.topics = true
    fetch.max.bytes = 52428800
    fetch.max.wait.ms = 500
    fetch.min.bytes = 1
    group.id = MyintegrationGroup
    heartbeat.interval.ms = 3000
    interceptor.classes = null
    key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
    max.partition.fetch.bytes = 1048576
    max.poll.interval.ms = 300000
    max.poll.records = 500
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.sample.window.ms = 30000
    partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    receive.buffer.bytes = 65536
    reconnect.backoff.ms = 50
    request.timeout.ms = 305000
    retry.backoff.ms = 100
    sasl.kerberos.kinit.cmd = /usr/bin/kinit
    sasl.kerberos.min.time.before.relogin = 60000
    sasl.kerberos.service.name = null
    sasl.kerberos.ticket.renew.jitter = 0.05
    sasl.kerberos.ticket.renew.window.factor = 0.8
    sasl.mechanism = GSSAPI
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    ssl.endpoint.identification.algorithm = null
    ssl.key.password = null
    ssl.keymanager.algorithm = SunX509
    ssl.keystore.location = null
    ssl.keystore.password = null
    ssl.keystore.type = JKS
    ssl.protocol = TLS
    ssl.provider = null
    ssl.secure.random.implementation = null
    ssl.trustmanager.algorithm = PKIX
    ssl.truststore.location = null
    ssl.truststore.password = null
    ssl.truststore.type = JKS
    value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2019-02-16 00:01:15.892  INFO 4326 --- [pool-9-thread-1] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2019-02-16 00:01:15.893  INFO 4326 --- [pool-9-thread-1] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
`
Princelo commented 5 years ago

I would treat this as an Invalid one: Spring Integration has no knowledge about Feign. So, this is most likely an issue on that side.

To triage this kind of issues properly I would suggest to start from the StackOverflow.

but I agree with Gary that we (or all others on Feign project side, or on StackOverflow) need much more info to investigate issue and so.

Thanks for understanding.

Thanks, I'll ask StackOverflow for help.

artembilan commented 5 years ago

Why do you confuse us with Apache Kafka here? I don't mind to have it in the sample, project, but this information in the issue just doesn't help. And so much logs about Kafka sends us away from the original issue.

Can you just explain what does this mean:

But once the @FeignClient instance wired to(by @Autowired) any config Class(@configuration), it's not working.

How can we reproduce this? We can't infer an issue from logs of your own project. Any chances to have a simple project from you to let us to play with and reproduce. Although I still think that it's not Spring Integration issue... That's fully might be the way how Feign works...

Please, learn also how to comment properly here on GitHub: https://help.github.com/articles/basic-writing-and-formatting-syntax/

Princelo commented 5 years ago

It's a simple project that explains this problem: https://github.com/Princelo/demoForSiAndFeignProblem/blob/master/src/main/java/com/example/demo/config/AnyConfig.java

artembilan commented 5 years ago

Looks like this SO question is related: https://stackoverflow.com/questions/54713649/spring-integration-http-inbound-gateway-not-working-when-feignclient-instance-wi

artembilan commented 5 years ago

I found what is the problem. The Spring Integration's IntegrationRequestMappingHandlerMapping doesn't check for the ApplicaitonContext in the onApplicationEvent(ContextRefreshedEvent event). but since each Feign Client is wrapped to its own ApplicaitonContext (see FeignContext JavaDocs), so we react over there to wrong ContextRefreshedEvent and initialize this component for nothing.

Unfortunately the only workaround for now is something like copy and past the content of the IntegrationRequestMappingHandlerMapping into a new class, because that one is final and override its onApplicationEvent() like this:

public void onApplicationEvent(ContextRefreshedEvent event) {
        if (getApplicationContext().equals(event.getApplicationContext()) && !this.initialized.getAndSet(true)) {
            super.afterPropertiesSet();
        }
}

Then we need to declare that in our context like this:

@Bean(name = HttpContextUtils.HANDLER_MAPPING_BEAN_NAME)
    public HandlerMapping integrationRequestMappingHandlerMapping() {
        EnhancedIntegrationRequestMappingHandlerMapping enhancedIntegrationRequestMappingHandlerMapping =
                new EnhancedIntegrationRequestMappingHandlerMapping();
        enhancedIntegrationRequestMappingHandlerMapping.setOrder(0);
        return enhancedIntegrationRequestMappingHandlerMapping;
    }

The order and bean name must be exactly like those.

Another way might be like @Lazy annotation alongside with that @Autowired where you inject AnyFeignClient. This way the FeightClientFactoryBean is not going to be resolved immediately and, therefore, those separate application contexts won't be created and refreshed too early.