kafka-broker-receiver

gistfile1.txt

➜  certs git:(main) ✗ kubectl logs kafka-broker-receiver-6d948bcfd7-4qct2 -n knative-eventing
Picked up JAVA_TOOL_OPTIONS: -XX:+CrashOnOutOfMemoryError
{"@timestamp":"2026-01-17T09:34:25.877597755Z","@version":"1","message":"Registering tracing configurations protocol=NONE sampleRate=0.0 loggingDebugEnabled=false","logger_name":"dev.knative.eventing.kafka.broker.core.observability.tracing.TracingProvider","thread_name":"main","level":"INFO","level_value":20000,"protocol":"NONE","sampleRate":0.0,"loggingDebugEnabled":false}
{"@timestamp":"2026-01-17T09:34:25.907533297Z","@version":"1","message":"Starting Receiver env=ReceiverEnv{ingressPort=8080, livenessProbePath='/healthz', readinessProbePath='/readyz', httpServerConfigFilePath='/etc/config/config-kafka-broker-httpserver.properties'} BaseEnv{producerConfigFilePath='/etc/config/config-kafka-broker-producer.properties', dataPlaneConfigFilePath='/etc/brokers-triggers/data', metricsPublishQuantiles=false}","logger_name":"dev.knative.eventing.kafka.broker.receiver.main.Main","thread_name":"main","level":"INFO","level_value":20000,"env":{"producerConfigFilePath":"/etc/config/config-kafka-broker-producer.properties","dataPlaneConfigFilePath":"/etc/brokers-triggers/data","metricsJvmEnabled":false,"metricsHTTPClientEnabled":false,"metricsHTTPServerEnabled":false,"configFeaturesPath":"/etc/features","configObservabilityPath":"/etc/observability","waitStartupSeconds":8,"ingressPort":8080,"ingressTLSPort":8443,"livenessProbePath":"/healthz","readinessProbePath":"/readyz","httpServerConfigFilePath":"/etc/config/config-kafka-broker-httpserver.properties","publishQuantilesEnabled":false}}
{"@timestamp":"2026-01-17T09:34:25.92985588Z","@version":"1","message":"Metrics cert paths weren't provided, server will start without TLS","logger_name":"dev.knative.eventing.kafka.broker.core.observability.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:25.929888255Z","@version":"1","message":"Metrics server host wasn't provided, using default value 0.0.0.0","logger_name":"dev.knative.eventing.kafka.broker.core.observability.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.06692113Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"main","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.20126638Z","@version":"1","message":"Started watching /etc/features/authentication-oidc","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.211484588Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-6","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.211877005Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-5","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.211958338Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-6","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.212103672Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-3","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.212297797Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-0","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.21248588Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-2","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.21253363Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-3","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.212626963Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-5","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.212656422Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-0","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.21291688Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-4","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.21318788Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-7","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.21349688Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-2","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.213550838Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-7","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.213776213Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-4","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.214121213Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-9","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.214110922Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-8","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.214537713Z","@version":"1","message":"The following httpclient factories were detected on your classpath: [io.fabric8.kubernetes.client.vertx.VertxHttpClientFactory, io.fabric8.kubernetes.client.jdkhttp.JdkHttpClientFactory], multiple of which had the same priority (0) so one was chosen randomly. You should exclude dependencies that aren't needed or use an explicit association of the HttpClient.Factory.","logger_name":"io.fabric8.kubernetes.client.utils.HttpClientUtils","thread_name":"vert.x-eventloop-thread-1","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.214944797Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-1","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.215221672Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-8","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.215555213Z","@version":"1","message":"You're already on a Vert.x context, are you sure you want to create a new Vertx instance?","logger_name":"io.vertx.core.impl.VertxImpl","thread_name":"vert.x-eventloop-thread-9","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:26.299155963Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.300462172Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.300551963Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.300827047Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.301002088Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.301202755Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.301440713Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.301741005Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.301943588Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.302099213Z","@version":"1","message":"Started watching /etc/receiver-tls-secret/tls.crt","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.302552422Z","@version":"1","message":"Receiver started","logger_name":"dev.knative.eventing.kafka.broker.receiver.main.Main","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.306749213Z","@version":"1","message":"Started watching /etc/brokers-triggers/data","logger_name":"dev.knative.eventing.kafka.broker.core.file.FileWatcher","thread_name":"contract-file-watcher","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:26.410060672Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410060797Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410060755Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410141672Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410060755Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410170172Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410172714Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410175172Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410180005Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410191214Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410284672Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410276589Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410310547Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410349172Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.41041538Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410415922Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410432172Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410437005Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410834005Z","@version":"1","message":"Set new contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.410912089Z","@version":"1","message":"Reconciling contract contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411311339Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411629172Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411250464Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411723422Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411222714Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411639839Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411364255Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411333589Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411559547Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:26.411445464Z","@version":"1","message":"Reconcile ingress diff diff=DiffResult{added=[eff4c67c-c572-45c7-9e1d-2a98714fa87c], intersection=[], removed=[]} contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerImpl","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000,"diff":{"added":["eff4c67c-c572-45c7-9e1d-2a98714fa87c"],"intersection":[],"removed":[]},"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:27.453804881Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-3\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453804922Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-5\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453937589Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-9\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453944506Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-4\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453949089Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-8\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453862631Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-2\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.453865631Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-1\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.454471464Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-6\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.454480297Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-10\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.454552964Z","@version":"1","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [kafka-sebi-avat6ar.c.aivencloud.com:18981]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = producer-7\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 600000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = false\n\tenable.metrics.push = true\n\tinterceptor.classes = [io.cloudevents.kafka.PartitionKeyExtensionInterceptor]\n\tkey.serializer = class org.apache.kafka.common.serialization.StringSerializer\n\tlinger.ms = 0\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = -1\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = SSL\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = [hidden]\n\tssl.keystore.key = [hidden]\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = PEM\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = [hidden]\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = PEM\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class io.cloudevents.kafka.CloudEventSerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472208589Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472208547Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472254797Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472268172Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472208589Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472297839Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472211631Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472326714Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472338422Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.472348922Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:27.518046922Z","@version":"1","message":"[Producer clientId=producer-2] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-0","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519012006Z","@version":"1","message":"[Producer clientId=producer-3] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-4","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519054922Z","@version":"1","message":"[Producer clientId=producer-1] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-3","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519301422Z","@version":"1","message":"[Producer clientId=producer-7] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-7","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519741589Z","@version":"1","message":"[Producer clientId=producer-8] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-6","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519773672Z","@version":"1","message":"[Producer clientId=producer-4] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-1","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.519849339Z","@version":"1","message":"[Producer clientId=producer-6] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-5","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.520006047Z","@version":"1","message":"[Producer clientId=producer-10] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-9","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.520343214Z","@version":"1","message":"[Producer clientId=producer-9] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-8","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:27.520456339Z","@version":"1","message":"[Producer clientId=producer-5] DefaultPartitioner is deprecated.  Please clear partitioner.class configuration setting to get the default partitioning behavior","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"vert.x-eventloop-thread-2","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:28.277720423Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.278163131Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.279460089Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.279543256Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.279556923Z","@version":"1","message":"Kafka startTimeMs: 1768642468277","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.279691506Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.279811339Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282054423Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282385464Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282402339Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282425214Z","@version":"1","message":"Kafka startTimeMs: 1768642468282","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282875048Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282889923Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.282893298Z","@version":"1","message":"Kafka startTimeMs: 1768642468278","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.283283839Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.283302089Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.283311131Z","@version":"1","message":"Kafka startTimeMs: 1768642468279","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.285177548Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.285203339Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.285208631Z","@version":"1","message":"Kafka startTimeMs: 1768642468279","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.286925256Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.286972298Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.286983756Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.286988131Z","@version":"1","message":"Kafka startTimeMs: 1768642468286","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.287207923Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.339773464Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.340347589Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.340361923Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.340366006Z","@version":"1","message":"Kafka startTimeMs: 1768642468339","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.340752214Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.341475548Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.341501631Z","@version":"1","message":"Kafka startTimeMs: 1768642468287","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.341582923Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.353456964Z","@version":"1","message":"These configurations '[cloudevents.serializer.event_format]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354220964Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354276964Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354290214Z","@version":"1","message":"Kafka startTimeMs: 1768642468353","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354782881Z","@version":"1","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354828423Z","@version":"1","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.354843006Z","@version":"1","message":"Kafka startTimeMs: 1768642468341","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:28.468964964Z","@version":"1","message":"The client is using resource type 'eventtypes' with unstable version 'v1beta2'","logger_name":"io.fabric8.kubernetes.client.dsl.internal.VersionUsageUtils","thread_name":"vert.x-eventloop-thread-7","level":"WARN","level_value":30000}
{"@timestamp":"2026-01-17T09:34:28.54558434Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-5","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.545827006Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-8","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.546410965Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-3","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.546651465Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-1","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.546890256Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-7","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.54749784Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-6","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.548006131Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-4","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.548078673Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-0","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.548389506Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-9","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:28.54851384Z","@version":"1","message":"Reconciled contract generation contractGeneration=2","logger_name":"dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler","thread_name":"vert.x-eventloop-thread-2","level":"INFO","level_value":20000,"contractGeneration":2}
{"@timestamp":"2026-01-17T09:34:29.53346109Z","@version":"1","message":"[Producer clientId=producer-3] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.53346109Z","@version":"1","message":"[Producer clientId=producer-9] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-9","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.53351034Z","@version":"1","message":"[Producer clientId=producer-6] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-6","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533526798Z","@version":"1","message":"[Producer clientId=producer-1] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533525882Z","@version":"1","message":"[Producer clientId=producer-10] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-10","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533463715Z","@version":"1","message":"[Producer clientId=producer-7] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-7","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533599173Z","@version":"1","message":"[Producer clientId=producer-5] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-5","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533627465Z","@version":"1","message":"[Producer clientId=producer-8] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-8","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.53369784Z","@version":"1","message":"[Producer clientId=producer-2] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-01-17T09:34:29.533732298Z","@version":"1","message":"[Producer clientId=producer-4] Cluster ID: 703833ba-8097-aa2e-0087-8bb1a7aaaa05","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | producer-4","level":"INFO","level_value":20000}