Skip to content

Instantly share code, notes, and snippets.

@codeskine

codeskine/File Source

Created October 2, 2017 10:40
Show Gist options
  • Save codeskine/fb8fcf2830799c133674341c97632d42 to your computer and use it in GitHub Desktop.
Save codeskine/fb8fcf2830799c133674341c97632d42 to your computer and use it in GitHub Desktop.
Download ZIP
App Log
Raw
File Source
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v1.5.7.RELEASE)
2017-10-02 12:29:13.790 INFO 17615 --- [ main] e.w.c.s.a.f.s.FileSourceApplication : Starting FileSourceApplication v0.0.1-SNAPSHOT on stopalpanico with PID 17615 (/home/stefano/.m2/repository/eu/wheesbee/cloud/stream/app/wheesbee-cloud-source-file/0.0.1-SNAPSHOT/wheesbee-cloud-source-file-0.0.1-SNAPSHOT.jar started by stefano in /tmp/spring-cloud-dataflow-8611631291609148818/untar-1506940151301/untar.file)
2017-10-02 12:29:13.808 INFO 17615 --- [ main] e.w.c.s.a.f.s.FileSourceApplication : No active profile set, falling back to default profiles: default
2017-10-02 12:29:14.027 INFO 17615 --- [ main] ationConfigEmbeddedWebApplicationContext : Refreshing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2077d4de: startup date [Mon Oct 02 12:29:14 CEST 2017]; root of context hierarchy
2017-10-02 12:29:15.979 INFO 17615 --- [ main] o.s.i.config.IntegrationRegistrar : No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created.
2017-10-02 12:29:17.823 INFO 17615 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created.
2017-10-02 12:29:17.827 INFO 17615 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'taskScheduler' has been explicitly defined. Therefore, a default ThreadPoolTaskScheduler will be created.
2017-10-02 12:29:18.219 INFO 17615 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.kafka.annotation.KafkaBootstrapConfiguration' of type [org.springframework.kafka.annotation.KafkaBootstrapConfiguration$$EnhancerBySpringCGLIB$$d7fc42d7] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:18.288 INFO 17615 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.stream.config.BindingServiceConfiguration$PostProcessorConfiguration' of type [org.springframework.cloud.stream.config.BindingServiceConfiguration$PostProcessorConfiguration$$EnhancerBySpringCGLIB$$c611cf59] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:18.726 INFO 17615 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration' of type [org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration$$EnhancerBySpringCGLIB$$4868949] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:18.760 INFO 17615 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'spelConverter' of type [org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration$SpelConverter] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:18.839 INFO 17615 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.cloud.stream.integration-org.springframework.cloud.stream.config.SpringIntegrationProperties' of type [org.springframework.cloud.stream.config.SpringIntegrationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:19.038 INFO 17615 --- [ 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)
2017-10-02 12:29:19.043 INFO 17615 --- [ 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)
2017-10-02 12:29:20.125 INFO 17615 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 36311 (http)
2017-10-02 12:29:20.181 INFO 17615 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2017-10-02 12:29:20.182 INFO 17615 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet Engine: Apache Tomcat/8.5.20
2017-10-02 12:29:20.524 INFO 17615 --- [ost-startStop-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2017-10-02 12:29:20.524 INFO 17615 --- [ost-startStop-1] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 6501 ms
2017-10-02 12:29:21.409 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean : Mapping servlet: 'dispatcherServlet' to [/]
2017-10-02 12:29:21.419 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'metricsFilter' to: [/*]
2017-10-02 12:29:21.420 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'characterEncodingFilter' to: [/*]
2017-10-02 12:29:21.420 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
2017-10-02 12:29:21.422 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'httpPutFormContentFilter' to: [/*]
2017-10-02 12:29:21.422 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'requestContextFilter' to: [/*]
2017-10-02 12:29:21.422 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'webRequestLoggingFilter' to: [/*]
2017-10-02 12:29:21.423 INFO 17615 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'applicationContextIdFilter' to: [/*]
2017-10-02 12:29:21.642 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class eu.wheesbee.cloud.stream.app.file.source.FileSourceProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.643 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class eu.wheesbee.cloud.stream.app.file.source.FileSourceProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.643 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class eu.wheesbee.cloud.stream.app.file.source.FileSourceProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.703 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.file.FileConsumerProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.704 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.file.FileConsumerProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.708 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.file.FileConsumerProperties contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.815 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.trigger.TriggerPropertiesMaxMessagesDefaultUnlimited contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.816 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.trigger.TriggerPropertiesMaxMessagesDefaultUnlimited contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.817 WARN 17615 --- [ main] figurationPropertiesBindingPostProcessor : The @ConfigurationProperties bean class org.springframework.cloud.stream.app.trigger.TriggerPropertiesMaxMessagesDefaultUnlimited contains validation constraints but had not been annotated with @Validated.
2017-10-02 12:29:21.888 INFO 17615 --- [ main] o.s.c.s.a.trigger.TriggerConfiguration : Trigger type: org.springframework.scheduling.support.PeriodicTrigger@21dffd
2017-10-02 12:29:23.318 INFO 17615 --- [ main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 'taskScheduler'
2017-10-02 12:29:24.154 INFO 17615 --- [ main] s.w.s.m.m.a.RequestMappingHandlerAdapter : Looking for @ControllerAdvice: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2077d4de: startup date [Mon Oct 02 12:29:14 CEST 2017]; root of context hierarchy
2017-10-02 12:29:24.488 INFO 17615 --- [ 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)
2017-10-02 12:29:24.490 INFO 17615 --- [ 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)
2017-10-02 12:29:24.683 INFO 17615 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:24.683 INFO 17615 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:24.850 INFO 17615 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:25.561 INFO 17615 --- [ 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
2017-10-02 12:29:25.562 INFO 17615 --- [ 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()
2017-10-02 12:29:25.564 INFO 17615 --- [ 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)
2017-10-02 12:29:25.565 INFO 17615 --- [ 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()
2017-10-02 12:29:25.566 INFO 17615 --- [ 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)
2017-10-02 12:29:25.569 INFO 17615 --- [ main] o.s.b.a.e.mvc.EndpointHandlerMapping : Mapped "{[/shutdown || /shutdown.json],methods=[POST],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.ShutdownMvcEndpoint.invoke()
2017-10-02 12:29:25.571 INFO 17615 --- [ 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()
2017-10-02 12:29:25.571 INFO 17615 --- [ 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()
2017-10-02 12:29:25.574 INFO 17615 --- [ 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()
2017-10-02 12:29:25.575 INFO 17615 --- [ 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()
2017-10-02 12:29:25.578 INFO 17615 --- [ 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)
2017-10-02 12:29:25.579 INFO 17615 --- [ 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>)
2017-10-02 12:29:25.579 INFO 17615 --- [ 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()
2017-10-02 12:29:25.580 INFO 17615 --- [ 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()
2017-10-02 12:29:25.582 INFO 17615 --- [ 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)
2017-10-02 12:29:25.582 INFO 17615 --- [ 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()
2017-10-02 12:29:25.583 INFO 17615 --- [ 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)
2017-10-02 12:29:25.584 INFO 17615 --- [ 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()
2017-10-02 12:29:25.584 INFO 17615 --- [ 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()
2017-10-02 12:29:25.979 INFO 17615 --- [ main] o.s.i.codec.kryo.CompositeKryoRegistrar : configured Kryo registration [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-10-02 12:29:26.213 INFO 17615 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup
2017-10-02 12:29:26.231 INFO 17615 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Bean with name 'integrationMbeanExporter' has been autodetected for JMX exposure
2017-10-02 12:29:26.238 INFO 17615 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Located managed bean 'integrationMbeanExporter': registering with JMX server as MBean [untar.file:name=integrationMbeanExporter,type=IntegrationMBeanExporter]
2017-10-02 12:29:26.520 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering beans for JMX exposure on startup
2017-10-02 12:29:26.520 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel errorChannel
2017-10-02 12:29:26.525 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.file:type=MessageChannel,name=errorChannel': registering with JMX server as MBean [untar.file:type=MessageChannel,name=errorChannel]
2017-10-02 12:29:26.607 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel output
2017-10-02 12:29:26.609 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.file:type=MessageChannel,name=output': registering with JMX server as MBean [untar.file:type=MessageChannel,name=output]
2017-10-02 12:29:26.627 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel nullChannel
2017-10-02 12:29:26.628 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.file:type=MessageChannel,name=nullChannel': registering with JMX server as MBean [untar.file:type=MessageChannel,name=nullChannel]
2017-10-02 12:29:26.646 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageHandler errorLogger
2017-10-02 12:29:26.648 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.file:type=MessageHandler,name=errorLogger,bean=internal': registering with JMX server as MBean [untar.file:type=MessageHandler,name=errorLogger,bean=internal]
2017-10-02 12:29:26.684 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.file:type=ManagedEndpoint,name=org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0,bean=endpoint': registering with JMX server as MBean [untar.file:type=ManagedEndpoint,name=org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0,bean=endpoint]
2017-10-02 12:29:26.689 INFO 17615 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registered endpoint without MessageSource: untar.file:type=ManagedEndpoint,name=org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0,bean=endpoint
2017-10-02 12:29:26.701 INFO 17615 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase -2147482648
2017-10-02 12:29:26.795 INFO 17615 --- [ main] e.w.c.s.a.f.s.FileSourceApplication : No active profile set, falling back to default profiles: default
2017-10-02 12:29:26.805 INFO 17615 --- [ main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@6c61a903: startup date [Mon Oct 02 12:29:26 CEST 2017]; parent: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2077d4de
2017-10-02 12:29:26.897 INFO 17615 --- [ main] o.s.c.s.b.k.c.KafkaBinderConfiguration : AdminUtils selected: Kafka 0.10 AdminUtils
2017-10-02 12:29:26.956 INFO 17615 --- [ main] e.w.c.s.a.f.s.FileSourceApplication : Started FileSourceApplication in 0.233 seconds (JVM running for 15.345)
2017-10-02 12:29:26.985 INFO 17615 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Using kafka topic for outbound: untar.file
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:host.name=stopalpanico
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.version=1.8.0_144
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.vendor=Oracle Corporation
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.home=/usr/lib/jvm/java-8-oracle/jre
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.class.path=/home/stefano/.m2/repository/eu/wheesbee/cloud/stream/app/wheesbee-cloud-source-file/0.0.1-SNAPSHOT/wheesbee-cloud-source-file-0.0.1-SNAPSHOT.jar
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.io.tmpdir=/tmp
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.compiler=<NA>
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.name=Linux
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.arch=amd64
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.version=4.10.0-35-generic
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.name=stefano
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.home=/home/stefano
2017-10-02 12:29:27.044 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.dir=/tmp/spring-cloud-dataflow-8611631291609148818/untar-1506940151301/untar.file
2017-10-02 12:29:27.045 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@fcb4004
2017-10-02 12:29:27.070 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:27.079 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:27.089 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d0032, negotiated timeout = 10000
2017-10-02 12:29:27.597 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Session: 0x15edc22fc9d0032 closed
2017-10-02 12:29:27.597 INFO 17615 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@704f1591
2017-10-02 12:29:27.597 INFO 17615 --- [ain-EventThread] org.apache.zookeeper.ClientCnxn : EventThread shut down for session: 0x15edc22fc9d0032
2017-10-02 12:29:27.599 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:27.599 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:27.601 INFO 17615 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d0033, negotiated timeout = 10000
2017-10-02 12:29:27.637 INFO 17615 --- [ main] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:27.643 INFO 17615 --- [ main] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:27.679 INFO 17615 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 0.10.1.1
2017-10-02 12:29:27.680 INFO 17615 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : f10ef2720b03b247
2017-10-02 12:29:27.794 INFO 17615 --- [ main] o.a.k.clients.producer.KafkaProducer : Closing the Kafka producer with timeoutMillis = 30000 ms.
2017-10-02 12:29:27.805 INFO 17615 --- [ main] o.s.integration.channel.DirectChannel : Channel 'application:0.output' has 1 subscriber(s).
2017-10-02 12:29:27.806 INFO 17615 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 0
2017-10-02 12:29:27.860 INFO 17615 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2017-10-02 12:29:27.860 INFO 17615 --- [ main] o.s.i.channel.PublishSubscribeChannel : Channel 'application:0.errorChannel' has 1 subscriber(s).
2017-10-02 12:29:27.860 INFO 17615 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started _org.springframework.integration.errorLogger
2017-10-02 12:29:27.860 INFO 17615 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 1073741823
2017-10-02 12:29:27.863 INFO 17615 --- [ main] o.s.i.e.SourcePollingChannelAdapter : started org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0
2017-10-02 12:29:27.863 INFO 17615 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 2147482647
2017-10-02 12:29:27.863 INFO 17615 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 2147483647
2017-10-02 12:29:27.869 INFO 17615 --- [ask-scheduler-1] o.s.i.file.FileReadingMessageSource : Created message: [GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch1.tgz, headers={id=7f4fda3a-f506-a188-85b8-9fd9778752fc, timestamp=1506940167869}]]
2017-10-02 12:29:27.874 INFO 17615 --- [ask-scheduler-1] o.s.i.codec.kryo.CompositeKryoRegistrar : registering [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-10-02 12:29:27.889 INFO 17615 --- [ask-scheduler-1] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:27.892 INFO 17615 --- [ask-scheduler-1] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:27.897 INFO 17615 --- [ask-scheduler-1] o.a.kafka.common.utils.AppInfoParser : Kafka version : 0.10.1.1
2017-10-02 12:29:27.897 INFO 17615 --- [ask-scheduler-1] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : f10ef2720b03b247
2017-10-02 12:29:27.937 INFO 17615 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 36311 (http)
2017-10-02 12:29:27.940 INFO 17615 --- [ main] e.w.c.s.a.f.s.FileSourceApplication : Started FileSourceApplication in 14.967 seconds (JVM running for 16.329)
2017-10-02 12:38:28.013 INFO 17615 --- [ask-scheduler-3] o.s.i.file.FileReadingMessageSource : Created message: [GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={id=0b99b840-e3b3-f742-44ec-707aeea638c8, timestamp=1506940708013}]]
Raw
Untar processord
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v1.5.7.RELEASE)
2017-10-02 12:29:11.185 INFO 17591 --- [ main] e.w.c.s.a.c.u.p.UnTarApplication : Starting UnTarApplication v0.0.1-SNAPSHOT on stopalpanico with PID 17591 (/home/stefano/.m2/repository/eu/wheesbee/cloud/stream/app/wheesbee-cloud-processor-untar/0.0.1-SNAPSHOT/wheesbee-cloud-processor-untar-0.0.1-SNAPSHOT.jar started by stefano in /tmp/spring-cloud-dataflow-8611631291609148818/untar-1506940149229/untar.untar)
2017-10-02 12:29:11.191 INFO 17591 --- [ main] e.w.c.s.a.c.u.p.UnTarApplication : No active profile set, falling back to default profiles: default
2017-10-02 12:29:11.311 INFO 17591 --- [ main] ationConfigEmbeddedWebApplicationContext : Refreshing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2957fcb0: startup date [Mon Oct 02 12:29:11 CEST 2017]; root of context hierarchy
2017-10-02 12:29:13.271 INFO 17591 --- [ main] o.s.i.config.IntegrationRegistrar : No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created.
2017-10-02 12:29:14.903 INFO 17591 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created.
2017-10-02 12:29:14.906 INFO 17591 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'taskScheduler' has been explicitly defined. Therefore, a default ThreadPoolTaskScheduler will be created.
2017-10-02 12:29:15.290 INFO 17591 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.kafka.annotation.KafkaBootstrapConfiguration' of type [org.springframework.kafka.annotation.KafkaBootstrapConfiguration$$EnhancerBySpringCGLIB$$a63bda40] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:15.420 INFO 17591 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.stream.config.BindingServiceConfiguration$PostProcessorConfiguration' of type [org.springframework.cloud.stream.config.BindingServiceConfiguration$PostProcessorConfiguration$$EnhancerBySpringCGLIB$$945166c2] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:15.795 INFO 17591 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration' of type [org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration$$EnhancerBySpringCGLIB$$d2c620b2] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:15.852 INFO 17591 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'spelConverter' of type [org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration$SpelConverter] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:15.890 INFO 17591 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.cloud.stream.integration-org.springframework.cloud.stream.config.SpringIntegrationProperties' of type [org.springframework.cloud.stream.config.SpringIntegrationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-10-02 12:29:16.043 INFO 17591 --- [ 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)
2017-10-02 12:29:16.046 INFO 17591 --- [ 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)
2017-10-02 12:29:17.091 INFO 17591 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 27334 (http)
2017-10-02 12:29:17.132 INFO 17591 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2017-10-02 12:29:17.134 INFO 17591 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet Engine: Apache Tomcat/8.5.20
2017-10-02 12:29:17.409 INFO 17591 --- [ost-startStop-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2017-10-02 12:29:17.409 INFO 17591 --- [ost-startStop-1] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 6103 ms
2017-10-02 12:29:18.081 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean : Mapping servlet: 'dispatcherServlet' to [/]
2017-10-02 12:29:18.089 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'metricsFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'characterEncodingFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'httpPutFormContentFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'requestContextFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'webRequestLoggingFilter' to: [/*]
2017-10-02 12:29:18.090 INFO 17591 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'applicationContextIdFilter' to: [/*]
2017-10-02 12:29:19.510 INFO 17591 --- [ main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 'taskScheduler'
2017-10-02 12:29:20.334 INFO 17591 --- [ main] s.w.s.m.m.a.RequestMappingHandlerAdapter : Looking for @ControllerAdvice: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2957fcb0: startup date [Mon Oct 02 12:29:11 CEST 2017]; root of context hierarchy
2017-10-02 12:29:20.655 INFO 17591 --- [ 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)
2017-10-02 12:29:20.657 INFO 17591 --- [ 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)
2017-10-02 12:29:20.799 INFO 17591 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:20.799 INFO 17591 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:20.966 INFO 17591 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
2017-10-02 12:29:22.194 INFO 17591 --- [ 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()
2017-10-02 12:29:22.213 INFO 17591 --- [ 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)
2017-10-02 12:29:22.214 INFO 17591 --- [ 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>)
2017-10-02 12:29:22.214 INFO 17591 --- [ 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()
2017-10-02 12:29:22.218 INFO 17591 --- [ 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()
2017-10-02 12:29:22.219 INFO 17591 --- [ 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()
2017-10-02 12:29:22.221 INFO 17591 --- [ 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)
2017-10-02 12:29:22.221 INFO 17591 --- [ 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()
2017-10-02 12:29:22.225 INFO 17591 --- [ 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)
2017-10-02 12:29:22.226 INFO 17591 --- [ 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)
2017-10-02 12:29:22.227 INFO 17591 --- [ 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()
2017-10-02 12:29:22.236 INFO 17591 --- [ 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()
2017-10-02 12:29:22.237 INFO 17591 --- [ 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()
2017-10-02 12:29:22.274 INFO 17591 --- [ 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()
2017-10-02 12:29:22.275 INFO 17591 --- [ 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()
2017-10-02 12:29:22.276 INFO 17591 --- [ 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
2017-10-02 12:29:22.277 INFO 17591 --- [ 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()
2017-10-02 12:29:22.280 INFO 17591 --- [ 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)
2017-10-02 12:29:22.284 INFO 17591 --- [ main] o.s.b.a.e.mvc.EndpointHandlerMapping : Mapped "{[/shutdown || /shutdown.json],methods=[POST],produces=[application/vnd.spring-boot.actuator.v1+json || application/json]}" onto public java.lang.Object org.springframework.boot.actuate.endpoint.mvc.ShutdownMvcEndpoint.invoke()
2017-10-02 12:29:23.402 INFO 17591 --- [ main] o.s.i.codec.kryo.CompositeKryoRegistrar : configured Kryo registration [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-10-02 12:29:23.658 INFO 17591 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup
2017-10-02 12:29:23.681 INFO 17591 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Bean with name 'integrationMbeanExporter' has been autodetected for JMX exposure
2017-10-02 12:29:23.692 INFO 17591 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Located managed bean 'integrationMbeanExporter': registering with JMX server as MBean [untar.untar:name=integrationMbeanExporter,type=IntegrationMBeanExporter]
2017-10-02 12:29:23.833 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering beans for JMX exposure on startup
2017-10-02 12:29:23.833 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel input
2017-10-02 12:29:23.838 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageChannel,name=input': registering with JMX server as MBean [untar.untar:type=MessageChannel,name=input]
2017-10-02 12:29:23.964 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel errorChannel
2017-10-02 12:29:23.971 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageChannel,name=errorChannel': registering with JMX server as MBean [untar.untar:type=MessageChannel,name=errorChannel]
2017-10-02 12:29:24.042 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel output
2017-10-02 12:29:24.044 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageChannel,name=output': registering with JMX server as MBean [untar.untar:type=MessageChannel,name=output]
2017-10-02 12:29:24.086 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel nullChannel
2017-10-02 12:29:24.088 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageChannel,name=nullChannel': registering with JMX server as MBean [untar.untar:type=MessageChannel,name=nullChannel]
2017-10-02 12:29:24.117 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel process.channel#1
2017-10-02 12:29:24.119 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageChannel,name=process.channel#1': registering with JMX server as MBean [untar.untar:type=MessageChannel,name=process.channel#1]
2017-10-02 12:29:24.148 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageHandler errorLogger
2017-10-02 12:29:24.154 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageHandler,name=errorLogger,bean=internal': registering with JMX server as MBean [untar.untar:type=MessageHandler,name=errorLogger,bean=internal]
2017-10-02 12:29:24.197 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageHandler input
2017-10-02 12:29:24.200 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageHandler,name=input,bean=anonymous': registering with JMX server as MBean [untar.untar:type=MessageHandler,name=input,bean=anonymous]
2017-10-02 12:29:24.221 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Registering MessageHandler process.channel#1
2017-10-02 12:29:24.223 INFO 17591 --- [ main] o.s.i.monitor.IntegrationMBeanExporter : Located managed bean 'untar.untar:type=MessageHandler,name=process.channel#1,bean=anonymous': registering with JMX server as MBean [untar.untar:type=MessageHandler,name=process.channel#1,bean=anonymous]
2017-10-02 12:29:24.262 INFO 17591 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase -2147482648
2017-10-02 12:29:24.421 INFO 17591 --- [ main] e.w.c.s.a.c.u.p.UnTarApplication : No active profile set, falling back to default profiles: default
2017-10-02 12:29:24.440 INFO 17591 --- [ main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@4470fbd6: startup date [Mon Oct 02 12:29:24 CEST 2017]; parent: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@2957fcb0
2017-10-02 12:29:24.616 INFO 17591 --- [ main] o.s.c.s.b.k.c.KafkaBinderConfiguration : AdminUtils selected: Kafka 0.10 AdminUtils
2017-10-02 12:29:24.801 INFO 17591 --- [ main] e.w.c.s.a.c.u.p.UnTarApplication : Started UnTarApplication in 0.484 seconds (JVM running for 15.3)
2017-10-02 12:29:24.931 INFO 17591 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner : Using kafka topic for outbound: untar.untar
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:host.name=stopalpanico
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.version=1.8.0_144
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.vendor=Oracle Corporation
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.home=/usr/lib/jvm/java-8-oracle/jre
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.class.path=/home/stefano/.m2/repository/eu/wheesbee/cloud/stream/app/wheesbee-cloud-processor-untar/0.0.1-SNAPSHOT/wheesbee-cloud-processor-untar-0.0.1-SNAPSHOT.jar
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.io.tmpdir=/tmp
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:java.compiler=<NA>
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.name=Linux
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.arch=amd64
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:os.version=4.10.0-35-generic
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.name=stefano
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.home=/home/stefano
2017-10-02 12:29:25.033 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Client environment:user.dir=/tmp/spring-cloud-dataflow-8611631291609148818/untar-1506940149229/untar.untar
2017-10-02 12:29:25.034 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@4ff4357f
2017-10-02 12:29:25.073 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:25.083 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:25.093 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d002e, negotiated timeout = 10000
2017-10-02 12:29:25.718 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Session: 0x15edc22fc9d002e closed
2017-10-02 12:29:25.721 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@37c7595
2017-10-02 12:29:25.719 INFO 17591 --- [ain-EventThread] org.apache.zookeeper.ClientCnxn : EventThread shut down for session: 0x15edc22fc9d002e
2017-10-02 12:29:25.726 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:25.727 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:25.730 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d002f, negotiated timeout = 10000
2017-10-02 12:29:25.805 INFO 17591 --- [ main] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:25.816 INFO 17591 --- [ main] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
block.on.buffer.full = false
bootstrap.servers = [localhost: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.ByteArraySerializer
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
2017-10-02 12:29:25.869 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 0.10.1.1
2017-10-02 12:29:25.869 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : f10ef2720b03b247
2017-10-02 12:29:26.000 INFO 17591 --- [ main] o.a.k.clients.producer.KafkaProducer : Closing the Kafka producer with timeoutMillis = 30000 ms.
2017-10-02 12:29:26.018 INFO 17591 --- [ main] o.s.integration.channel.DirectChannel : Channel 'application:0.output' has 1 subscriber(s).
2017-10-02 12:29:26.019 INFO 17591 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 0
2017-10-02 12:29:26.084 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2017-10-02 12:29:26.086 INFO 17591 --- [ main] o.s.i.channel.PublishSubscribeChannel : Channel 'application:0.errorChannel' has 1 subscriber(s).
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started _org.springframework.integration.errorLogger
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {} as a subscriber to the 'input' channel
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.integration.channel.DirectChannel : Channel 'application:0.input' has 1 subscriber(s).
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started org.springframework.integration.config.ConsumerEndpointFactoryBean#0
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {splitter} as a subscriber to the 'process.channel#1' channel
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.integration.channel.DirectChannel : Channel 'application:0.process.channel#1' has 1 subscriber(s).
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started org.springframework.integration.config.ConsumerEndpointFactoryBean#1
2017-10-02 12:29:26.087 INFO 17591 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 2147482647
2017-10-02 12:29:26.115 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@5c8504fd
2017-10-02 12:29:26.118 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:26.118 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:26.122 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d0030, negotiated timeout = 10000
2017-10-02 12:29:26.273 INFO 17591 --- [ main] kafka.admin.AdminUtils$ : Topic creation {"version":1,"partitions":{"0":[0]}}
2017-10-02 12:29:26.281 INFO 17591 --- [ain-EventThread] org.apache.zookeeper.ClientCnxn : EventThread shut down for session: 0x15edc22fc9d0030
2017-10-02 12:29:26.281 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Session: 0x15edc22fc9d0030 closed
2017-10-02 12:29:26.321 INFO 17591 --- [ main] org.apache.zookeeper.ZooKeeper : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.I0Itec.zkclient.ZkClient@6475472c
2017-10-02 12:29:26.343 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2017-10-02 12:29:26.343 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Socket connection established to localhost/127.0.0.1:2181, initiating session
2017-10-02 12:29:26.345 INFO 17591 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15edc22fc9d0031, negotiated timeout = 10000
2017-10-02 12:29:26.379 INFO 17591 --- [ main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values:
auto.commit.interval.ms = 100
auto.offset.reset = latest
bootstrap.servers = [localhost: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 = untar
heartbeat.interval.ms = 3000
interceptor.classes = null
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
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.ByteArrayDeserializer
2017-10-02 12:29:26.380 INFO 17591 --- [ main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values:
auto.commit.interval.ms = 100
auto.offset.reset = latest
bootstrap.servers = [localhost: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 = untar
heartbeat.interval.ms = 3000
interceptor.classes = null
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
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.ByteArrayDeserializer
2017-10-02 12:29:26.458 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 0.10.1.1
2017-10-02 12:29:26.458 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : f10ef2720b03b247
2017-10-02 12:29:26.586 INFO 17591 --- [ main] o.s.c.stream.binder.BinderErrorChannel : Channel 'application:0.untar.file.untar.errors' has 1 subscriber(s).
2017-10-02 12:29:26.587 INFO 17591 --- [ main] o.s.c.stream.binder.BinderErrorChannel : Channel 'application:0.untar.file.untar.errors' has 0 subscriber(s).
2017-10-02 12:29:26.588 INFO 17591 --- [ main] o.s.c.stream.binder.BinderErrorChannel : Channel 'application:0.untar.file.untar.errors' has 1 subscriber(s).
2017-10-02 12:29:26.588 INFO 17591 --- [ main] o.s.c.stream.binder.BinderErrorChannel : Channel 'application:0.untar.file.untar.errors' has 2 subscriber(s).
2017-10-02 12:29:26.598 INFO 17591 --- [ main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values:
auto.commit.interval.ms = 100
auto.offset.reset = latest
bootstrap.servers = [localhost: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 = untar
heartbeat.interval.ms = 3000
interceptor.classes = null
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
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.ByteArrayDeserializer
2017-10-02 12:29:26.599 INFO 17591 --- [ main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values:
auto.commit.interval.ms = 100
auto.offset.reset = latest
bootstrap.servers = [localhost: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 = untar
heartbeat.interval.ms = 3000
interceptor.classes = null
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
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.ByteArrayDeserializer
2017-10-02 12:29:26.601 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 0.10.1.1
2017-10-02 12:29:26.601 INFO 17591 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : f10ef2720b03b247
2017-10-02 12:29:26.605 INFO 17591 --- [ main] s.i.k.i.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter@5b1f29fa
2017-10-02 12:29:26.613 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {message-handler:inbound.untar.file.untar} as a subscriber to the 'bridge.untar.file' channel
2017-10-02 12:29:26.613 INFO 17591 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started inbound.untar.file.untar
2017-10-02 12:29:26.614 INFO 17591 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 2147483647
2017-10-02 12:29:26.709 INFO 17591 --- [ -C-1] o.a.k.c.c.internals.AbstractCoordinator : Discovered coordinator stopalpanico:9092 (id: 2147483647 rack: null) for group untar.
2017-10-02 12:29:26.720 INFO 17591 --- [ -C-1] o.a.k.c.c.internals.ConsumerCoordinator : Revoking previously assigned partitions [] for group untar
2017-10-02 12:29:26.720 INFO 17591 --- [ -C-1] o.s.c.s.b.k.KafkaMessageChannelBinder$3 : partitions revoked:[]
2017-10-02 12:29:26.720 INFO 17591 --- [ -C-1] o.a.k.c.c.internals.AbstractCoordinator : (Re-)joining group untar
2017-10-02 12:29:26.750 INFO 17591 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 27334 (http)
2017-10-02 12:29:26.753 INFO 17591 --- [ main] e.w.c.s.a.c.u.p.UnTarApplication : Started UnTarApplication in 16.426 seconds (JVM running for 17.252)
2017-10-02 12:29:28.019 INFO 17591 --- [ -C-1] o.a.k.c.c.internals.AbstractCoordinator : Successfully joined group untar with generation 2
2017-10-02 12:29:28.026 INFO 17591 --- [ -C-1] o.a.k.c.c.internals.ConsumerCoordinator : Setting newly assigned partitions [untar.file-0] for group untar
2017-10-02 12:29:28.042 INFO 17591 --- [ -C-1] o.s.c.s.b.k.KafkaMessageChannelBinder$3 : partitions assigned:[untar.file-0]
2017-10-02 12:38:28.077 INFO 17591 --- [ -L-1] o.s.i.codec.kryo.CompositeKryoRegistrar : registering [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2017-10-02 12:38:28.080 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Message 'GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={kafka_offset=1, id=1a4d4b9c-86fe-d3a8-d800-8013e8ae7027, kafka_receivedPartitionId=0, contentType=application/x-java-object;type=java.io.File, kafka_receivedTopic=untar.file, timestamp=1506940708079}]' unpacking started...
2017-10-02 12:38:28.080 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Check message's payload type to decompress
2017-10-02 12:38:29.106 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Message 'GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={kafka_offset=1, id=cd611ca4-4cd9-0624-0871-dcf93a9a0051, kafka_receivedPartitionId=0, contentType=application/x-java-object;type=java.io.File, kafka_receivedTopic=untar.file, timestamp=1506940709106}]' unpacking started...
2017-10-02 12:38:29.107 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Check message's payload type to decompress
2017-10-02 12:38:31.108 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Message 'GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={kafka_offset=1, id=97171a2e-29ac-2111-b838-3da7220f5e3c, kafka_receivedPartitionId=0, contentType=application/x-java-object;type=java.io.File, kafka_receivedTopic=untar.file, timestamp=1506940711108}]' unpacking started...
2017-10-02 12:38:31.108 INFO 17591 --- [ -L-1] .w.c.s.a.c.p.AbstractCompressTransformer : Check message's payload type to decompress
2017-10-02 12:38:31.116 ERROR 17591 --- [ -L-1] o.s.integration.handler.LoggingHandler : org.springframework.integration.transformer.MessageTransformationException: failed to transform message; nested exception is org.springframework.messaging.MessageHandlingException: Failed to apply Zip transformation.; nested exception is java.io.FileNotFoundException: /tmp/patent/CNINO_im_201733_batch108.tgz (File o directory non esistente), failedMessage=GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={kafka_offset=1, id=97171a2e-29ac-2111-b838-3da7220f5e3c, kafka_receivedPartitionId=0, contentType=application/x-java-object;type=java.io.File, kafka_receivedTopic=untar.file, timestamp=1506940711108}], failedMessage=GenericMessage [payload=/tmp/patent/CNINO_im_201733_batch108.tgz, headers={kafka_offset=1, id=97171a2e-29ac-2111-b838-3da7220f5e3c, kafka_receivedPartitionId=0, contentType=application/x-java-object;type=java.io.File, kafka_receivedTopic=untar.file, timestamp=1506940711108}]
at org.springframework.integration.transformer.AbstractTransformer.transform(AbstractTransformer.java:44)
at org.springframework.integration.transformer.MessageTransformingHandler.handleRequestMessage(MessageTransformingHandler.java:89)
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:109)
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116)
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:148)
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:89)
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:425)
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:375)
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:360)
at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:271)
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:188)
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:115)
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:70)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment