Welcome to fish, the friendly interactive shell Type `help` for instructions on how to use fish <@kanadi>-<⎇ update-docker-compose>-> docker ps -a CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES 16aa9cdce60d ghcr.io/adyach/nakadi-docker/nakadi:3.5 "/bin/sh -c 'exec ja…" 28 seconds ago Up 27 seconds 0.0.0.0:8080->8080/tcp, :::8080->8080/tcp kanadi-nakadi-1 67360b7f1341 ghcr.io/adyach/kafka-docker/kafka-docker:2.7.0 "start-kafka.sh" 28 seconds ago Up 27 seconds 0.0.0.0:9092->9092/tcp, :::9092->9092/tcp kanadi-kafka-1 b42d08605dd6 ghcr.io/adyach/nakadi-docker/postgres:3.5 "docker-entrypoint.s…" 29 seconds ago Up 28 seconds 0.0.0.0:5432->5432/tcp, :::5432->5432/tcp kanadi-postgres-1 92c5f646d6c6 ghcr.io/adyach/nakadi-docker/zookeeper:3.6.3 "/bin/sh -c 'bash /o…" 29 seconds ago Up 28 seconds 2888/tcp, 0.0.0.0:2181->2181/tcp, :::2181->2181/tcp, 3888/tcp kanadi-zookeeper-1 <@kanadi>-<⎇ update-docker-compose>-> docker logs --follow 16aa9cdce60d . ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_| | ) ) ) ) ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.5.12) [2023-08-18 12:42:54.874Z] [INFO] [null] [main] [org.zalando.nakadi.Application] --- Starting Application using Java 11.0.16 on 16aa9cdce60d with PID 1 (/nakadi.jar started by root in /) [2023-08-18 12:42:54.875Z] [DEBUG] [null] [main] [org.zalando.nakadi.Application] --- Running with Spring Boot v2.5.12, Spring v5.3.18 [2023-08-18 12:42:54.876Z] [INFO] [null] [main] [org.zalando.nakadi.Application] --- The following 1 profile is active: "local" [2023-08-18 12:42:56.011Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'metricsConfig' of type [org.zalando.nakadi.config.MetricsConfig$$EnhancerBySpringCGLIB$$7b866fe2] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.081Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'metricRegistry' of type [com.codahale.metrics.MetricRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.082Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'metricsConfigurerAdapter' of type [org.zalando.nakadi.config.MetricsConfig$1] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.083Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'com.ryantenney.metrics.spring.config.annotation.DelegatingMetricsConfiguration' of type [com.ryantenney.metrics.spring.config.annotation.DelegatingMetricsConfiguration$$EnhancerBySpringCGLIB$$302a213a] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.088Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'getMetricRegistry' of type [com.codahale.metrics.MetricRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.098Z] [INFO] [null] [main] [org.springframework.context.support.PostProcessorRegistrationDelegate$BeanPostProcessorChecker] --- Bean 'getHealthCheckRegistry' of type [com.codahale.metrics.health.HealthCheckRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) [2023-08-18 12:42:56.149Z] [INFO] [null] [main] [org.eclipse.jetty.util.log] --- Logging initialized @2042ms to org.eclipse.jetty.util.log.Slf4jLog [2023-08-18 12:42:56.240Z] [INFO] [null] [main] [org.springframework.boot.web.embedded.jetty.JettyServletWebServerFactory] --- Server initialized with port: 8080 [2023-08-18 12:42:56.253Z] [INFO] [null] [main] [org.eclipse.jetty.server.Server] --- jetty-9.4.45.v20220203; built: 2022-02-03T09:14:34.105Z; git: 4a0c91c0be53805e3fcffdcdcc9587d5301863db; jvm 11.0.16+8 [2023-08-18 12:42:56.267Z] [INFO] [null] [main] [org.eclipse.jetty.server.handler.ContextHandler.application] --- Initializing Spring embedded WebApplicationContext [2023-08-18 12:42:56.267Z] [INFO] [null] [main] [org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext] --- Root WebApplicationContext: initialization completed in 1356 ms [2023-08-18 12:42:56.303Z] [INFO] [null] [main] [org.zalando.nakadi.config.PluginsConfig] --- Initialize per-resource authorization service factory: org.crazycoder.nakadiauthzfileplugin.FileAuthorizationServiceFactory [2023-08-18 12:42:56.400Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:zookeeper.version=3.6.1--104dcb3e3fb464b30c5186d229e00af9f332524b, built on 04/21/2020 15:01 GMT [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:host.name=16aa9cdce60d [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.version=11.0.16 [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.vendor=Oracle Corporation [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.home=/usr/local/openjdk-11 [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.class.path=nakadi.jar [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.io.tmpdir=/tmp [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:java.compiler= [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.name=Linux [2023-08-18 12:42:56.404Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.arch=amd64 [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.version=6.4.9-1-MANJARO [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:user.name=root [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:user.home=/root [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:user.dir=/ [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.memory.free=782MB [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.memory.max=8008MB [2023-08-18 12:42:56.405Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Client environment:os.memory.total=808MB [2023-08-18 12:42:56.407Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@7807ac2c [2023-08-18 12:42:56.410Z] [INFO] [null] [main] [org.apache.zookeeper.common.X509Util] --- Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation [2023-08-18 12:42:56.413Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:42:56.417Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:42:56.423Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:42:56.424Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:42:56.424Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:42:56.426Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:42:56.426Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@30ed9c6c [2023-08-18 12:42:56.426Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:42:56.426Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:42:56.427Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:42:56.427Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:42:56.427Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:42:56.428Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:38672, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:42:56.428Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:38670, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:42:56.440Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040002, negotiated timeout = 10000 [2023-08-18 12:42:56.440Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040001, negotiated timeout = 10000 [2023-08-18 12:42:56.442Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature DISABLE_EVENT_TYPE_DELETION to false [2023-08-18 12:42:56.444Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:42:56.444Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:42:56.451Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:56.451Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:56.451Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:56.451Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:56.460Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature disable_event_type_deletion was already disabled [2023-08-18 12:42:56.460Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature DISABLE_EVENT_TYPE_CREATION to false [2023-08-18 12:42:56.464Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature disable_event_type_creation was already disabled [2023-08-18 12:42:56.464Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature KPI_COLLECTION to true [2023-08-18 12:42:56.471Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature kpi_collection enabled [2023-08-18 12:42:56.471Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature DISABLE_DB_WRITE_OPERATIONS to false [2023-08-18 12:42:56.473Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature disable_db_write_operations was already disabled [2023-08-18 12:42:56.473Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature FORCE_SUBSCRIPTION_AUTHZ to false [2023-08-18 12:42:56.475Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature force_subscription_authz was already disabled [2023-08-18 12:42:56.475Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature EVENT_OWNER_SELECTOR_AUTHZ to false [2023-08-18 12:42:56.479Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature event_owner_selector_authz was already disabled [2023-08-18 12:42:56.479Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature FORCE_EVENT_TYPE_AUTHZ to false [2023-08-18 12:42:56.481Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature force_event_type_authz was already disabled [2023-08-18 12:42:56.481Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature DISABLE_SUBSCRIPTION_CREATION to false [2023-08-18 12:42:56.483Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature disable_subscription_creation was already disabled [2023-08-18 12:42:56.483Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature REMOTE_TOKENINFO to true [2023-08-18 12:42:56.486Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature remote_tokeninfo enabled [2023-08-18 12:42:56.486Z] [INFO] [null] [main] [org.zalando.nakadi.config.RepositoriesConfig] --- Setting feature ACCESS_LOG_ENABLED to true [2023-08-18 12:42:56.488Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.FeatureToggleService] --- Feature access_log_enabled enabled [2023-08-18 12:42:56.645Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Started updates [2023-08-18 12:42:56.733Z] [INFO] [null] [main] [org.zalando.nakadi.partitioning.HashPartitionStrategyCrutch] --- Initialized partitions override map with 0 values: [2023-08-18 12:42:56.961Z] [INFO] [null] [main] [org.zalando.zmon.actuator.ZmonRestFilterBeanPostProcessor] --- Added org.zalando.zmon.actuator.ZmonRestFilterBeanPostProcessor instance to restTemplate [2023-08-18 12:42:57.020Z] [WARN] [null] [main] [org.springframework.boot.autoconfigure.security.servlet.UserDetailsServiceAutoConfiguration] --- Using generated security password: e549d285-85de-4a5f-b569-0e99ff2e81b7 This generated password is for development use only. Your security configuration must be updated before running your application in production. [2023-08-18 12:42:57.147Z] [INFO] [null] [main] [org.zalando.nakadi.config.SecurityConfiguration] --- Authentication mode: OFF [2023-08-18 12:42:57.154Z] [WARN] [null] [main] [org.springframework.security.config.annotation.web.builders.WebSecurity] --- You are asking Spring Security to ignore any request. This is not recommended -- please use permitAll via HttpSecurity#authorizeHttpRequests instead. [2023-08-18 12:42:57.154Z] [INFO] [null] [main] [org.springframework.security.web.DefaultSecurityFilterChain] --- Will secure any request with [] [2023-08-18 12:42:57.175Z] [INFO] [null] [main] [org.springframework.security.web.DefaultSecurityFilterChain] --- Will not secure any request [2023-08-18 12:42:57.186Z] [INFO] [null] [main] [org.springframework.security.web.DefaultSecurityFilterChain] --- Will not secure any request [2023-08-18 12:42:57.270Z] [INFO] [null] [main] [org.springframework.boot.web.servlet.RegistrationBean] --- Filter springSecurityFilterChain was not registered (possibly already registered?) [2023-08-18 12:42:57.344Z] [INFO] [null] [main] [org.eclipse.jetty.server.session] --- DefaultSessionIdManager workerName=node0 [2023-08-18 12:42:57.344Z] [INFO] [null] [main] [org.eclipse.jetty.server.session] --- No SessionScavenger set, using defaults [2023-08-18 12:42:57.346Z] [INFO] [null] [main] [org.eclipse.jetty.server.session] --- node0 Scavenging every 600000ms [2023-08-18 12:42:57.353Z] [INFO] [null] [main] [org.eclipse.jetty.server.handler.ContextHandler] --- Started o.s.b.w.e.j.JettyEmbeddedWebAppContext@76f856a8{application,/,[file:///tmp/jetty-docbase.8080.15715897523652335192/],AVAILABLE} [2023-08-18 12:42:57.354Z] [INFO] [null] [main] [org.eclipse.jetty.server.Server] --- Started @3248ms [2023-08-18 12:42:57.485Z] [INFO] [null] [main] [org.zalando.nakadi.service.StorageService] --- Creating storage `default` from defaults [2023-08-18 12:42:57.567Z] [INFO] [null] [main] [org.zalando.nakadi.config.PluginsConfig] --- Initialize application service factory: org.zalando.nakadi.plugin.auth.DefaultApplicationServiceFactory [2023-08-18 12:42:57.574Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.SystemEventTypeInitializer] --- Initializing event types from disk_usage_event_type.json [2023-08-18 12:42:57.607Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.disk.usage as it is missing [2023-08-18 12:42:57.655Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:42:57.656Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@3ce53f6a [2023-08-18 12:42:57.656Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:42:57.656Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:42:57.656Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:42:57.656Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:42:57.656Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:42:57.656Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:38690, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:42:57.657Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:42:57.657Z] [INFO] [null] [main] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@53ed09e8 [2023-08-18 12:42:57.657Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:42:57.657Z] [INFO] [null] [main] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:42:57.658Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:42:57.658Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:42:57.658Z] [INFO] [null] [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:42:57.658Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:38692, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:42:57.659Z] [INFO] [null] [main] [org.zalando.nakadi.repository.kafka.KafkaLocationManager] --- Creating watcher on brokers change [2023-08-18 12:42:57.660Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040003, negotiated timeout = 10000 [2023-08-18 12:42:57.660Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:42:57.661Z] [INFO] [null] [main-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040004, negotiated timeout = 10000 [2023-08-18 12:42:57.661Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:42:57.662Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:57.662Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:57.662Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:57.662Z] [INFO] [null] [main-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:42:57.664Z] [INFO] [null] [main] [org.zalando.nakadi.repository.kafka.KafkaLocationManager] --- Kafka client bootstrap servers changed: kafka:9092 [2023-08-18 12:42:57.665Z] [INFO] [null] [main] [org.zalando.nakadi.repository.kafka.KafkaLocationManager] --- Creating watcher on brokers change [2023-08-18 12:42:57.667Z] [INFO] [null] [main] [org.zalando.nakadi.repository.kafka.KafkaLocationManager] --- Kafka client bootstrap servers changed: kafka:9092 [2023-08-18 12:42:58.133Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.disk.usage and triggering changes notification [2023-08-18 12:42:58.137Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.disk.usage because of remote notification [2023-08-18 12:42:58.141Z] [ERROR] [null] [main] [org.zalando.nakadi.service.publishing.NakadiKpiPublisher] --- Error occurred when submitting KPI event for publishing org.zalando.nakadi.exceptions.runtime.NoSuchSchemaException: schema is not found for nakadi.event.type.log at org.zalando.nakadi.service.SchemaService.lambda$findLatestSchemaVersion$7(SchemaService.java:341) at java.base/java.util.Optional.orElseThrow(Optional.java:408) at org.zalando.nakadi.service.SchemaService.findLatestSchemaVersion(SchemaService.java:340) at org.zalando.nakadi.service.SchemaService.lambda$getAvroSchemaVersion$5(SchemaService.java:309) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at org.zalando.nakadi.service.SchemaService.getAvroSchemaVersion(SchemaService.java:307) at org.zalando.nakadi.service.publishing.NakadiKpiPublisher.publish(NakadiKpiPublisher.java:79) at org.zalando.nakadi.service.EventTypeService.create(EventTypeService.java:230) at org.zalando.nakadi.service.EventTypeService.createIfMissing(EventTypeService.java:269) at org.zalando.nakadi.service.SystemEventTypeInitializer.lambda$createEventTypesFromResource$0(SystemEventTypeInitializer.java:52) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.zalando.nakadi.service.SystemEventTypeInitializer.createEventTypesFromResource(SystemEventTypeInitializer.java:50) at org.zalando.nakadi.service.job.DiskUsageStatsJob.prepareEventType(DiskUsageStatsJob.java:63) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:389) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeInitMethods(InitDestroyAnnotationBeanPostProcessor.java:333) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeInitialization(InitDestroyAnnotationBeanPostProcessor.java:157) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:440) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1796) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:620) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:953) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:448) at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1365) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354) at org.zalando.nakadi.Application.main(Application.java:12) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49) at org.springframework.boot.loader.Launcher.launch(Launcher.java:108) at org.springframework.boot.loader.Launcher.launch(Launcher.java:58) at org.springframework.boot.loader.PropertiesLauncher.main(PropertiesLauncher.java:467) [2023-08-18 12:42:58.149Z] [INFO] [null] [main] [org.zalando.nakadi.service.LoggingReconfigurator] --- Logging configuration changed, reloading (class path resource [log4j.properties]) [2023-08-18 12:42:58.225Z] [WARN] [null] [main] [org.zalando.nakadi.controller.VersionController] --- Failed to read scm-source.json file from /scm-source.json, file not found [2023-08-18 12:42:58.226Z] [INFO] [null] [main] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Starting initialization [2023-08-18 12:42:58.252Z] [INFO] [null] [timelines-refresh-1] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Upgrading version from 0 to 1000 [2023-08-18 12:42:58.252Z] [INFO] [null] [timelines-refresh-1] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Setting locked event types to [] [2023-08-18 12:42:58.253Z] [INFO] [null] [timelines-refresh-1] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Exposing self version 1000 [2023-08-18 12:42:58.255Z] [INFO] [null] [timelines-refresh-1] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Version upgrade finished [2023-08-18 12:42:58.255Z] [INFO] [null] [timelines-refresh-1] [timelines.node.36bd69cd-5a3a-4354-bc04-a9306f046544] --- Have to recreate listener. Previous zk version: null, New zk version: 0 [2023-08-18 12:42:58.519Z] [INFO] [null] [main] [org.springframework.boot.actuate.endpoint.web.EndpointLinksResolver] --- Exposing 1 endpoint(s) beneath base path '/actuator' [2023-08-18 12:42:58.549Z] [DEBUG] [null] [main] [org.zalando.nakadi.filters.TracingFilter] --- Filter 'tracingFilter' configured for use [2023-08-18 12:42:58.549Z] [DEBUG] [null] [main] [org.zalando.nakadi.filters.RequestRejectedFilter] --- Filter 'requestRejectedFilter' configured for use [2023-08-18 12:42:58.549Z] [DEBUG] [null] [main] [org.zalando.nakadi.filters.MonitoringRequestFilter] --- Filter 'monitoringRequestFilter' configured for use [2023-08-18 12:42:58.549Z] [DEBUG] [null] [main] [org.zalando.nakadi.filters.LoggingFilter] --- Filter 'loggingFilter' configured for use [2023-08-18 12:42:58.550Z] [DEBUG] [null] [main] [org.zalando.nakadi.filters.ExtraTracingFilter] --- Filter 'extraTracingFilter' configured for use [2023-08-18 12:42:58.552Z] [INFO] [null] [main] [org.eclipse.jetty.server.handler.ContextHandler.application] --- Initializing Spring DispatcherServlet 'dispatcherServlet' [2023-08-18 12:42:58.552Z] [INFO] [null] [main] [org.springframework.web.servlet.DispatcherServlet] --- Initializing Servlet 'dispatcherServlet' [2023-08-18 12:42:58.553Z] [INFO] [null] [main] [org.springframework.web.servlet.DispatcherServlet] --- Completed initialization in 1 ms [2023-08-18 12:42:58.562Z] [INFO] [null] [main] [org.eclipse.jetty.server.AbstractConnector] --- Started ServerConnector@25748410{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} [2023-08-18 12:42:58.563Z] [INFO] [null] [main] [org.springframework.boot.web.embedded.jetty.JettyWebServer] --- Jetty started on port(s) 8080 (http/1.1) with context path '/' [2023-08-18 12:42:58.571Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.SystemEventTypeInitializer] --- Initializing event types from kpi_event_types.json [2023-08-18 12:42:58.575Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.batch.published as it is missing [2023-08-18 12:42:58.707Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.batch.published and triggering changes notification [2023-08-18 12:42:58.710Z] [ERROR] [null] [main] [org.zalando.nakadi.service.publishing.NakadiKpiPublisher] --- Error occurred when submitting KPI event for publishing org.zalando.nakadi.exceptions.runtime.NoSuchSchemaException: schema is not found for nakadi.event.type.log at org.zalando.nakadi.service.SchemaService.lambda$findLatestSchemaVersion$7(SchemaService.java:341) at java.base/java.util.Optional.orElseThrow(Optional.java:408) at org.zalando.nakadi.service.SchemaService.findLatestSchemaVersion(SchemaService.java:340) at org.zalando.nakadi.service.SchemaService.lambda$getAvroSchemaVersion$5(SchemaService.java:309) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at org.zalando.nakadi.service.SchemaService.getAvroSchemaVersion(SchemaService.java:307) at org.zalando.nakadi.service.publishing.NakadiKpiPublisher.publish(NakadiKpiPublisher.java:79) at org.zalando.nakadi.service.EventTypeService.create(EventTypeService.java:230) at org.zalando.nakadi.service.EventTypeService.createIfMissing(EventTypeService.java:269) at org.zalando.nakadi.service.SystemEventTypeInitializer.lambda$createEventTypesFromResource$0(SystemEventTypeInitializer.java:52) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.zalando.nakadi.service.SystemEventTypeInitializer.createEventTypesFromResource(SystemEventTypeInitializer.java:50) at org.zalando.nakadi.service.NakadiKpiInitialization.onApplicationEvent(NakadiKpiInitialization.java:53) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.context.event.ApplicationListenerMethodAdapter.doInvoke(ApplicationListenerMethodAdapter.java:344) at org.springframework.context.event.ApplicationListenerMethodAdapter.processEvent(ApplicationListenerMethodAdapter.java:229) at org.springframework.context.event.ApplicationListenerMethodAdapter.onApplicationEvent(ApplicationListenerMethodAdapter.java:166) at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:176) at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:169) at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:143) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:421) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:378) at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:938) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:586) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:448) at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1365) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354) at org.zalando.nakadi.Application.main(Application.java:12) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49) at org.springframework.boot.loader.Launcher.launch(Launcher.java:108) at org.springframework.boot.loader.Launcher.launch(Launcher.java:58) at org.springframework.boot.loader.PropertiesLauncher.main(PropertiesLauncher.java:467) [2023-08-18 12:42:58.712Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.batch.published because of remote notification [2023-08-18 12:42:58.712Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.data.streamed as it is missing [2023-08-18 12:42:58.828Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.data.streamed and triggering changes notification [2023-08-18 12:42:58.831Z] [ERROR] [null] [main] [org.zalando.nakadi.service.publishing.NakadiKpiPublisher] --- Error occurred when submitting KPI event for publishing org.zalando.nakadi.exceptions.runtime.NoSuchSchemaException: schema is not found for nakadi.event.type.log at org.zalando.nakadi.service.SchemaService.lambda$findLatestSchemaVersion$7(SchemaService.java:341) at java.base/java.util.Optional.orElseThrow(Optional.java:408) at org.zalando.nakadi.service.SchemaService.findLatestSchemaVersion(SchemaService.java:340) at org.zalando.nakadi.service.SchemaService.lambda$getAvroSchemaVersion$5(SchemaService.java:309) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at org.zalando.nakadi.service.SchemaService.getAvroSchemaVersion(SchemaService.java:307) at org.zalando.nakadi.service.publishing.NakadiKpiPublisher.publish(NakadiKpiPublisher.java:79) at org.zalando.nakadi.service.EventTypeService.create(EventTypeService.java:230) at org.zalando.nakadi.service.EventTypeService.createIfMissing(EventTypeService.java:269) at org.zalando.nakadi.service.SystemEventTypeInitializer.lambda$createEventTypesFromResource$0(SystemEventTypeInitializer.java:52) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.zalando.nakadi.service.SystemEventTypeInitializer.createEventTypesFromResource(SystemEventTypeInitializer.java:50) at org.zalando.nakadi.service.NakadiKpiInitialization.onApplicationEvent(NakadiKpiInitialization.java:53) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.context.event.ApplicationListenerMethodAdapter.doInvoke(ApplicationListenerMethodAdapter.java:344) at org.springframework.context.event.ApplicationListenerMethodAdapter.processEvent(ApplicationListenerMethodAdapter.java:229) at org.springframework.context.event.ApplicationListenerMethodAdapter.onApplicationEvent(ApplicationListenerMethodAdapter.java:166) at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:176) at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:169) at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:143) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:421) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:378) at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:938) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:586) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:448) at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1365) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354) at org.zalando.nakadi.Application.main(Application.java:12) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49) at org.springframework.boot.loader.Launcher.launch(Launcher.java:108) at org.springframework.boot.loader.Launcher.launch(Launcher.java:58) at org.springframework.boot.loader.PropertiesLauncher.main(PropertiesLauncher.java:467) [2023-08-18 12:42:58.832Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.access.log as it is missing [2023-08-18 12:42:58.832Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.data.streamed because of remote notification [2023-08-18 12:42:58.937Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.access.log and triggering changes notification [2023-08-18 12:42:58.940Z] [ERROR] [null] [main] [org.zalando.nakadi.service.publishing.NakadiKpiPublisher] --- Error occurred when submitting KPI event for publishing org.zalando.nakadi.exceptions.runtime.NoSuchSchemaException: schema is not found for nakadi.event.type.log at org.zalando.nakadi.service.SchemaService.lambda$findLatestSchemaVersion$7(SchemaService.java:341) at java.base/java.util.Optional.orElseThrow(Optional.java:408) at org.zalando.nakadi.service.SchemaService.findLatestSchemaVersion(SchemaService.java:340) at org.zalando.nakadi.service.SchemaService.lambda$getAvroSchemaVersion$5(SchemaService.java:309) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at org.zalando.nakadi.service.SchemaService.getAvroSchemaVersion(SchemaService.java:307) at org.zalando.nakadi.service.publishing.NakadiKpiPublisher.publish(NakadiKpiPublisher.java:79) at org.zalando.nakadi.service.EventTypeService.create(EventTypeService.java:230) at org.zalando.nakadi.service.EventTypeService.createIfMissing(EventTypeService.java:269) at org.zalando.nakadi.service.SystemEventTypeInitializer.lambda$createEventTypesFromResource$0(SystemEventTypeInitializer.java:52) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.zalando.nakadi.service.SystemEventTypeInitializer.createEventTypesFromResource(SystemEventTypeInitializer.java:50) at org.zalando.nakadi.service.NakadiKpiInitialization.onApplicationEvent(NakadiKpiInitialization.java:53) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.context.event.ApplicationListenerMethodAdapter.doInvoke(ApplicationListenerMethodAdapter.java:344) at org.springframework.context.event.ApplicationListenerMethodAdapter.processEvent(ApplicationListenerMethodAdapter.java:229) at org.springframework.context.event.ApplicationListenerMethodAdapter.onApplicationEvent(ApplicationListenerMethodAdapter.java:166) at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:176) at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:169) at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:143) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:421) at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:378) at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:938) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:586) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:448) at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1365) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354) at org.zalando.nakadi.Application.main(Application.java:12) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49) at org.springframework.boot.loader.Launcher.launch(Launcher.java:108) at org.springframework.boot.loader.Launcher.launch(Launcher.java:58) at org.springframework.boot.loader.PropertiesLauncher.main(PropertiesLauncher.java:467) [2023-08-18 12:42:58.941Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.event.type.log as it is missing [2023-08-18 12:42:58.942Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.access.log because of remote notification [2023-08-18 12:42:58.989Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.event.type.log and triggering changes notification [2023-08-18 12:42:58.993Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.event.type.log because of remote notification [2023-08-18 12:42:59.001Z] [INFO] [null] [main] [org.zalando.nakadi.service.EventTypeService] --- Creating event-type nakadi.subscription.log as it is missing [2023-08-18 12:42:59.045Z] [INFO] [null] [main] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.subscription.log and triggering changes notification [2023-08-18 12:42:59.048Z] [DEBUG] [null] [main] [org.zalando.nakadi.service.NakadiAuditLogInitialization] --- Audit log collection is disabled, skip creation of audit log event type [2023-08-18 12:42:59.050Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type nakadi.subscription.log because of remote notification [2023-08-18 12:42:59.050Z] [INFO] [null] [main] [org.zalando.nakadi.Application] --- Started Application in 4.555 seconds (JVM running for 4.944) [2023-08-18 12:43:00.033Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.repository.kafka.KafkaFactory] --- New producer instance created: org.zalando.nakadi.repository.kafka.KafkaFactory$KafkaProducerCrutch@4a0fcf7a [2023-08-18 12:43:00.037Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type nakadi.event.type.log, took: 33 ms 16aa9cdce60d[2023-08-18 12:46:28.183Z] [INFO] [09b8eccf-3753-44b9-b118-2302acfc15b7] [qtp1157943921-66] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6 and triggering changes notification [2023-08-18 12:46:28.187Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6 because of remote notification [2023-08-18 12:46:28.191Z] [INFO] [09b8eccf-3753-44b9-b118-2302acfc15b7] [qtp1157943921-66] [ACCESS_LOG] --- POST "/event-types" "pekko-http/1.0.0" "-" 201 133ms "-" "-" 230B 0B [2023-08-18 12:46:28.264Z] [INFO] [77edfa13-ee1e-41f1-b181-c4192b4080cd] [qtp1157943921-17] [ACCESS_LOG] --- GET "/subscriptions?owning_application=KANADI&event_type=Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6" "pekko-http/1.0.0" "-" 200 15ms "-" "gzip, deflate" 0B 24B [2023-08-18 12:46:28.379Z] [INFO] [77edfa13-ee1e-41f1-b181-c4192b4080cd] [qtp1157943921-23] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6, took: 6 ms [2023-08-18 12:46:28.405Z] [INFO] [77edfa13-ee1e-41f1-b181-c4192b4080cd] [qtp1157943921-23] [ACCESS_LOG] --- POST "/subscriptions" "pekko-http/1.0.0" "-" 201 77ms "-" "gzip, deflate" 160B 373B [2023-08-18 12:46:28.475Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [qtp1157943921-18] [ACCESS_LOG] --- GET "/subscriptions/7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97/events" "pekko-http/1.0.0" "-" 102 0ms "-" "gzip, deflate" 0B 0B [2023-08-18 12:46:28.490Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Switching state from DummyState to StartingState [2023-08-18 12:46:28.516Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Creating sessions root [2023-08-18 12:46:28.524Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Creating offsets [2023-08-18 12:46:28.537Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Creating topology ZNode for Topology{partitions=[Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:0->UNASSIGNED:null->null], version=0} [2023-08-18 12:46:28.543Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- updating state [2023-08-18 12:46:28.553Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Registering session Session{ea938e5a-3a19-4155-be1c-66d70d840c8b, weight=1, requestedPartitions=[]} [2023-08-18 12:46:28.553Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Registering session Session{ea938e5a-3a19-4155-be1c-66d70d840c8b, weight=1, requestedPartitions=[]} [2023-08-18 12:46:28.562Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Switching state from StartingState to StreamingState [2023-08-18 12:46:28.572Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Updating topology to Topology{partitions=[Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:0->ASSIGNED:ea938e5a-3a19-4155-be1c-66d70d840c8b->null], version=1} [2023-08-18 12:46:28.583Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Adding to streaming EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'} with start position T(Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:1:NULL)-P(0)-O(-1) [2023-08-18 12:46:28.585Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Changing kafka assignment from [] to [EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'}] [2023-08-18 12:46:28.600Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [org.zalando.nakadi.service.timeline.MultiTimelineEventConsumer] --- Creating underlying consumer for client id null and cursors [T(Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:1:NULL)-P(0)-O(-1)] [2023-08-18 12:46:28.611Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Topology refreshed. Streaming partitions: [EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'}]. Reassigning partitions: [] [2023-08-18 12:46:28.611Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Topology changed not by event, but by schedule. Recreating zk listener [2023-08-18 12:46:29.204Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type nakadi.access.log, took: 7 ms [2023-08-18 12:46:29.416Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type nakadi.subscription.log, took: 13 ms [2023-08-18 12:46:29.683Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type nakadi.batch.published, took: 7 ms [2023-08-18 12:46:33.642Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.zk] --- Committing 001-0001-000000000000000001 to Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6/0 [2023-08-18 12:46:33.760Z] [ERROR] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'}] --- Commit in future: current: T(Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:1:NULL)-P(0)-O(-1), committed T(Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:1:NULL)-P(0)-O(-1) will skip sending obsolete data [2023-08-18 12:46:33.765Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Changing kafka assignment from [] to [EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'}] [2023-08-18 12:46:33.797Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [org.zalando.nakadi.service.timeline.MultiTimelineEventConsumer] --- Creating underlying consumer for client id null and cursors [T(Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6:1:NULL)-P(0)-O(000000000000000001)] [2023-08-18 12:46:59.682Z] [INFO] [null] [internal-event-batch-sender-1] [org.zalando.nakadi.cache.EventTypeCache] --- Successfully load event type nakadi.data.streamed, took: 10 ms [2023-08-18 12:47:37.295Z] [INFO] [null] [scheduling-1] [nakadi-job.disk-usage] --- Trying to run job... [2023-08-18 12:47:37.314Z] [INFO] [null] [scheduling-1] [nakadi-job.disk-usage] --- Job will be executed on this instance [2023-08-18 12:47:37.317Z] [ERROR] [null] [scheduling-1] [nakadi-job.disk-usage] --- Zookeeper error when performing job java.lang.RuntimeException: Failed to acquire size statistics at org.zalando.nakadi.repository.kafka.KafkaTopicRepository.getSizeStats(KafkaTopicRepository.java:683) at org.zalando.nakadi.service.job.DiskUsageStatsJob.loadDiskUsage(DiskUsageStatsJob.java:104) at org.zalando.nakadi.service.job.DiskUsageStatsJob.dumpDiskStatsLocked(DiskUsageStatsJob.java:80) at org.zalando.nakadi.service.job.ExclusiveJobWrapper.runJobLocked(ExclusiveJobWrapper.java:54) at org.zalando.nakadi.service.job.DiskUsageStatsJob.dumpDiskStats(DiskUsageStatsJob.java:73) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:84) at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /bubuku/size_stats at org.apache.zookeeper.KeeperException.create(KeeperException.java:118) at org.apache.zookeeper.KeeperException.create(KeeperException.java:54) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:2847) at org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:242) at org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:231) at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.pathInForeground(GetChildrenBuilderImpl.java:228) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:219) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:41) at org.zalando.nakadi.repository.kafka.KafkaZookeeper.getBrokerIdsForSizeStats(KafkaZookeeper.java:27) at org.zalando.nakadi.repository.kafka.KafkaTopicRepository.getSizeStats(KafkaTopicRepository.java:667) ... 16 more [2023-08-18 12:47:56.428Z] [INFO] [null] [pool-7-thread-1] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:47:56.430Z] [INFO] [null] [pool-7-thread-1] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@3a32702a [2023-08-18 12:47:56.432Z] [INFO] [null] [pool-7-thread-1] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:47:56.433Z] [INFO] [null] [pool-7-thread-1] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:47:56.436Z] [INFO] [null] [pool-7-thread-1] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:47:56.436Z] [INFO] [null] [pool-7-thread-1] [org.zalando.nakadi.repository.zookeeper.CuratorFrameworkRotator] --- curator client rotated, current usage 1 [2023-08-18 12:47:56.437Z] [INFO] [null] [pool-7-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:47:56.437Z] [INFO] [null] [pool-7-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:47:56.438Z] [INFO] [null] [pool-7-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:49758, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:47:56.449Z] [INFO] [null] [pool-7-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040005, negotiated timeout = 10000 [2023-08-18 12:47:56.450Z] [INFO] [null] [pool-7-thread-1-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:47:56.454Z] [INFO] [null] [pool-7-thread-1-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:47:56.455Z] [INFO] [null] [pool-7-thread-1-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:48:07.659Z] [INFO] [null] [pool-18-thread-1] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Starting [2023-08-18 12:48:07.660Z] [INFO] [null] [pool-18-thread-1] [org.apache.zookeeper.ZooKeeper] --- Initiating client connection, connectString=zookeeper:2181 sessionTimeout=10000 watcher=org.apache.curator.ConnectionState@4e9f1407 [2023-08-18 12:48:07.700Z] [INFO] [null] [pool-18-thread-1] [org.apache.zookeeper.ClientCnxnSocket] --- jute.maxbuffer value is 1048575 Bytes [2023-08-18 12:48:07.701Z] [INFO] [null] [pool-18-thread-1] [org.apache.zookeeper.ClientCnxn] --- zookeeper.request.timeout value is 0. feature enabled=false [2023-08-18 12:48:07.703Z] [INFO] [null] [pool-18-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Opening socket connection to server zookeeper/172.22.0.2:2181. [2023-08-18 12:48:07.703Z] [INFO] [null] [pool-18-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- SASL config status: Will not attempt to authenticate using SASL (unknown error) [2023-08-18 12:48:07.703Z] [INFO] [null] [pool-18-thread-1] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- Default schema [2023-08-18 12:48:07.703Z] [INFO] [null] [pool-18-thread-1] [org.zalando.nakadi.repository.zookeeper.CuratorFrameworkRotator] --- curator client rotated, current usage 0 [2023-08-18 12:48:07.704Z] [INFO] [null] [pool-18-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Socket connection established, initiating session, client: /172.22.0.5:37772, server: zookeeper/172.22.0.2:2181 [2023-08-18 12:48:07.706Z] [INFO] [null] [Curator-Framework-0] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- backgroundOperationsLoop exiting [2023-08-18 12:48:07.715Z] [INFO] [null] [pool-18-thread-1-SendThread(zookeeper:2181)] [org.apache.zookeeper.ClientCnxn] --- Session establishment complete on server zookeeper/172.22.0.2:2181, session id = 0x100004e3c040006, negotiated timeout = 10000 [2023-08-18 12:48:07.716Z] [INFO] [null] [pool-18-thread-1-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] --- State change: CONNECTED [2023-08-18 12:48:07.722Z] [INFO] [null] [pool-18-thread-1-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:48:07.722Z] [INFO] [null] [pool-18-thread-1-EventThread] [org.apache.curator.framework.imps.EnsembleTracker] --- New config event received: {} [2023-08-18 12:48:07.824Z] [INFO] [null] [pool-18-thread-1] [org.apache.zookeeper.ZooKeeper] --- Session: 0x100004e3c040004 closed [2023-08-18 12:48:07.824Z] [INFO] [null] [pool-18-thread-1] [org.zalando.nakadi.repository.zookeeper.CuratorFrameworkRotator] --- curator client recycled [2023-08-18 12:48:07.824Z] [INFO] [null] [main-EventThread] [org.apache.zookeeper.ClientCnxn] --- EventThread shut down for session: 0x100004e3c040004 [2023-08-18 12:48:57.630Z] [INFO] [null] [scheduling-1] [nakadi-job.timelines-cleanup] --- Trying to run job... [2023-08-18 12:48:57.652Z] [INFO] [null] [scheduling-1] [nakadi-job.timelines-cleanup] --- Job will be executed on this instance [2023-08-18 12:51:28.743Z] [INFO] [b0371ff3-677b-4d0f-8e64-7428a68dd035] [qtp1157943921-79] [ACCESS_LOG] --- GET "/subscriptions/7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97/stats" "pekko-http/1.0.0" "-" 200 22ms "-" "gzip, deflate" 0B 233B [2023-08-18 12:51:31.819Z] [INFO] [a837617c-116c-4982-ba21-3990a00be0de] [qtp1157943921-19] [ACCESS_LOG] --- DELETE "/subscriptions/7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97" "pekko-http/1.0.0" "-" 204 25ms "-" "gzip, deflate" 0B 0B [2023-08-18 12:51:31.866Z] [INFO] [ea449685-e517-4047-aa87-8c942c5cf861] [qtp1157943921-17] [org.zalando.nakadi.service.timeline.TimelineService] --- Deleting all timelines for event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6 [2023-08-18 12:51:31.875Z] [INFO] [ea449685-e517-4047-aa87-8c942c5cf861] [qtp1157943921-17] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6 and triggering changes notification [2023-08-18 12:51:31.879Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Invalidating event type Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6 because of remote notification [2023-08-18 12:51:31.880Z] [INFO] [null] [pool-9-thread-1] [org.zalando.nakadi.cache.EventTypeCache] --- Detected changes to remove, will try to remove 006b3a80-f17f-42f4-ab9c-058fd6f3f2bc [2023-08-18 12:51:31.900Z] [INFO] [ea449685-e517-4047-aa87-8c942c5cf861] [qtp1157943921-17] [ACCESS_LOG] --- DELETE "/event-types/Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6" "pekko-http/1.0.0" "-" 200 38ms "-" "-" 0B 0B [2023-08-18 12:51:31.901Z] [WARN] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Failed to process task org.zalando.nakadi.service.subscription.StreamingContext$$Lambda$1676/0x0000000840a3b840@3c821e, will rethrow original error [2023-08-18 12:51:31.901Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Cleaning task queue & Switching state immediately from StreamingState to CleanupState [2023-08-18 12:51:31.901Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Switching state from StreamingState to CleanupState [2023-08-18 12:51:31.903Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b.state.StreamingState] --- Removing partition EventTypePartition{eventType='Kanadi-Test-Event-519b8ff5-3469-420e-b172-24f3df530fe6', partition='0'} from streaming [2023-08-18 12:51:31.905Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [org.zalando.nakadi.controller.SubscriptionStreamController] --- Exception occurred while streaming: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /nakadi/subscriptions/7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97/sessions [2023-08-18 12:51:31.905Z] [WARN] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [org.zalando.nakadi.controller.SubscriptionStreamController] --- Response was already sent, cannot report error to the client [2023-08-18 12:51:31.905Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Unregistering session Session{ea938e5a-3a19-4155-be1c-66d70d840c8b, weight=1, requestedPartitions=[]} [2023-08-18 12:51:31.910Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [pool-10-thread-1] [s.7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97.ea938e5a-3a19-4155-be1c-66d70d840c8b] --- Switching state from CleanupState to DummyState [2023-08-18 12:51:31.918Z] [INFO] [null] [qtp1157943921-81] [org.zalando.nakadi.controller.advice.NakadiProblemExceptionHandler] --- Client closed connection [2023-08-18 12:51:31.919Z] [INFO] [a1618fd3-1231-4820-9f42-db6bea893921] [qtp1157943921-81] [ACCESS_LOG] --- GET "/subscriptions/7b1eab93-0fbf-4c9d-86e1-bfbbb8212d97/events" "pekko-http/1.0.0" "-" 200 303458ms "-" "gzip, deflate" 0B 1954B [2023-08-18 12:51:36.428Z] [INFO] [null] [Curator-Framework-0] [org.apache.curator.framework.imps.CuratorFrameworkImpl] --- backgroundOperationsLoop exiting [2023-08-18 12:51:36.539Z] [INFO] [null] [pool-7-thread-1] [org.apache.zookeeper.ZooKeeper] --- Session: 0x100004e3c040001 closed [2023-08-18 12:51:36.540Z] [INFO] [null] [pool-7-thread-1] [org.zalando.nakadi.repository.zookeeper.CuratorFrameworkRotator] --- curator client recycled [2023-08-18 12:51:36.539Z] [INFO] [null] [main-EventThread] [org.apache.zookeeper.ClientCnxn] --- EventThread shut down for session: 0x100004e3c040001