{"action":"created","issue":{"url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/812","repository_url":"https://api.github.com/repos/micronaut-projects/micronaut-core","labels_url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/812/labels{/name}","comments_url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/812/comments","events_url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/812/events","html_url":"https://github.com/micronaut-projects/micronaut-core/issues/812","id":375694724,"node_id":"MDU6SXNzdWUzNzU2OTQ3MjQ=","number":812,"title":"Kafka @SentTo Configuration Using Default Serdes","user":{"login":"ctoestreich","id":691357,"node_id":"MDQ6VXNlcjY5MTM1Nw==","avatar_url":"https://avatars3.githubusercontent.com/u/691357?v=4","gravatar_id":"","url":"https://api.github.com/users/ctoestreich","html_url":"https://github.com/ctoestreich","followers_url":"https://api.github.com/users/ctoestreich/followers","following_url":"https://api.github.com/users/ctoestreich/following{/other_user}","gists_url":"https://api.github.com/users/ctoestreich/gists{/gist_id}","starred_url":"https://api.github.com/users/ctoestreich/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ctoestreich/subscriptions","organizations_url":"https://api.github.com/users/ctoestreich/orgs","repos_url":"https://api.github.com/users/ctoestreich/repos","events_url":"https://api.github.com/users/ctoestreich/events{/privacy}","received_events_url":"https://api.github.com/users/ctoestreich/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2018-10-30T21:09:56Z","updated_at":"2018-10-30T21:30:05Z","closed_at":null,"author_association":"CONTRIBUTOR","body":"We are trying to use micronaut 1.0.0 to create a kafka streams application that will use custom serdes.  I have tried setting the values via code pros and yaml but the stream producer and consumer are still using the default `class org.apache.kafka.common.serialization.ByteArrayDeserializer`.  I will share the as much code.\r\n\r\nI tried almost every variation of consumer and provider configs to no avail.  I dug around the micronaut code to see if there was a missed value shuttle down to kafka, but I didn't see anything jump out.\r\n\r\n``` yaml\r\nconsumer.group: ${micronaut.application.name}-${random.int}\r\n\r\nkafka:\r\n  bootstrap:\r\n    servers: localhost:29092\r\n  consumers:\r\n    schema.registry.url: http://localhost:8081\r\n    security.protocol: PLAINTEXT\r\n    key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n    value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n    key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n    value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n    claim-v1-client:\r\n      destination: claimline-${random.int}\r\n      group: ${consumer.group}\r\n    ehb-v1-client:\r\n      destination: claimline.ehb-${random.int}\r\n      group: ${consumer.group}\r\n    default:\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n  consumer:\r\n    key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n    value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n    default:\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n  security.protocol: PLAINTEXT\r\n  schema.registry.url: http://localhost:8081\r\n  producers:\r\n    key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n    key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n    value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n    value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n  streams:\r\n    default:\r\n      num.stream.threads: 1\r\n      group.id: ${consumer.group}-${random.int}\r\n      client.id: ${consumer.group}-${random.int}\r\n      key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n      value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n      value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n      consumers:\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        default:\r\n          key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n          key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n          value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n          value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n          key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n          value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      consumer:\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n        default:\r\n          key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n          key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n          value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n          value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n          key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n          value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      producers:\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        default:\r\n          key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n          key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n          value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n          value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n          key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n          value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      producer:\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        default:\r\n          key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n          key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n          value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n          value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n          key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n          value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n    key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n    value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n    key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n    key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n    value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n    value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n    consumers:\r\n      key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n      value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n      value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n      default:\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n    consumer:\r\n      key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n      value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n      value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n      default:\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n    producers:\r\n      key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n      value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n      value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n      default:\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n    producer:\r\n      key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n      value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n      key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n      value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n      value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n      default:\r\n        key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde\r\n        value.serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n        key.serializer: org.apache.kafka.common.serialization.StringSerializer\r\n        value.deserializer: io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\r\n        value.serializer: io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\r\n```\r\n\r\n``` java\r\nimport io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer;\r\nimport io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer;\r\nimport io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder;\r\nimport io.micronaut.context.annotation.Factory;\r\nimport io.micronaut.context.annotation.Value;\r\nimport org.apache.avro.generic.GenericRecord;\r\nimport org.apache.kafka.clients.consumer.ConsumerConfig;\r\nimport org.apache.kafka.clients.producer.ProducerConfig;\r\nimport org.apache.kafka.common.serialization.Serdes;\r\nimport org.apache.kafka.streams.StreamsConfig;\r\nimport org.apache.kafka.streams.kstream.Consumed;\r\nimport org.apache.kafka.streams.kstream.KStream;\r\nimport org.apache.kafka.streams.kstream.Produced;\r\n\r\nimport javax.inject.Singleton;\r\nimport java.util.Properties;\r\n\r\n@Factory\r\npublic class EhbTransformerStream {\r\n\r\n    @Value(\"${kafka.consumers.claim-v1-client.destination}\")\r\n    private String inputTopic;\r\n    @Value(\"${kafka.consumers.ehb-v1-client.destination}\")\r\n    private String outputTopic;\r\n\r\n    @Singleton\r\n    KStream<String, GenericRecord> processStream(ConfiguredStreamBuilder builder) {\r\n        Properties props = builder.getConfiguration();\r\n        props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, \"earliest\");\r\n        props.put(\"acks\", \"all\");\r\n        props.put(\"retries\", 1);\r\n        props.put(\"batch.size\", 16384);\r\n        props.put(\"linger.ms\", 1);\r\n        props.put(\"buffer.memory\", 33554432);\r\n        props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());\r\n        props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, \"io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\");\r\n        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, \"org.apache.kafka.common.serialization.StringSerializer\");\r\n        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, \"io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer\");\r\n        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, \"org.apache.kafka.common.serialization.StringDeserializer\");\r\n        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, \"io.confluent.kafka.streams.serdes.avro.GenericAvroDeserializer\");\r\n\r\n        System.out.println(\"Input: \" + inputTopic);\r\n        System.out.println(\"Output: \" + outputTopic);\r\n\r\n        KStream<String, GenericRecord> source = builder.stream(inputTopic, Consumed.with(Serdes.String(), Serdes.serdeFrom(new GenericAvroSerializer(), new GenericAvroDeserializer())));\r\n        source.to(outputTopic, Produced.with(Serdes.String(), Serdes.serdeFrom(new GenericAvroSerializer(), new GenericAvroDeserializer())));\r\n        return source;\r\n    }\r\n}\r\n```\r\nDocker compose to run kafka stack\r\n\r\n``` yaml\r\nversion: \"3\"\r\n\r\nservices:\r\n  zookeeper:\r\n    image: zookeeper:3.4.9\r\n    restart: unless-stopped\r\n    hostname: zookeeper\r\n    ports:\r\n      - \"2181:2181\"\r\n    environment:\r\n        ZOO_MY_ID: 1\r\n        ZOO_PORT: 2181\r\n        ZOO_SERVERS: server.1=zookeeper:2888:3888\r\n\r\n  kafka:\r\n    image: confluentinc/cp-kafka:4.0.0\r\n    hostname: kafka\r\n    ports:\r\n      - \"9092:9092\"\r\n      - \"29092:29092\"\r\n    environment:\r\n      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT\r\n      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT\r\n      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092\r\n      #KAFKA_DELETE_TOPIC_ENABLE: \"true\"\r\n      #KAFKA_SCHEMA_REGISTRY_URL: \"kafka-schema-registry:8081\"\r\n      KAFKA_JMX_PORT: 9991\r\n      #KAFKA_BROKER_RACK: \"r1\"\r\n      #KAFKA_AUTO_CREATE_TOPICS_ENABLE: \"true\"\r\n      KAFKA_ZOOKEEPER_CONNECT: \"zookeeper:2181\"\r\n      KAFKA_BROKER_ID: 1\r\n      KAFKA_LOG4J_LOGGERS: \"kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO\"\r\n      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1\r\n      log.cleanup.policy: compact\r\n    depends_on:\r\n      - zookeeper\r\n\r\n  kafka-schema-registry:\r\n    image: confluentinc/cp-schema-registry:4.0.0\r\n    hostname: kafka-schema-registry\r\n    restart: unless-stopped\r\n    ports:\r\n      - \"8081:8081\"\r\n    environment:\r\n      SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: zookeeper:2181\r\n      SCHEMA_REGISTRY_HOST_NAME: kafka-schema-registry\r\n      SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8081\r\n    depends_on:\r\n      - zookeeper\r\n      - kafka\r\n\r\n  schema-registry-ui:\r\n    image: landoop/schema-registry-ui:0.9.4\r\n    hostname: kafka-schema-registry-ui\r\n    ports:\r\n      - \"8001:8000\"\r\n    environment:\r\n      SCHEMAREGISTRY_URL: http://kafka-schema-registry:8081/\r\n      PROXY: \"true\"\r\n    depends_on:\r\n      - kafka-schema-registry\r\n\r\n  kafka-rest-proxy:\r\n    image: confluentinc/cp-kafka-rest:4.0.0\r\n    hostname: kafka-rest-proxy\r\n    ports:\r\n      - \"8082:8082\"\r\n    environment:\r\n      KAFKA_REST_ZOOKEEPER_CONNECT: zookeeper:2181\r\n      KAFKA_REST_LISTENERS: http://0.0.0.0:8082/\r\n      KAFKA_REST_SCHEMA_REGISTRY_URL: http://kafka-schema-registry:8081/\r\n      KAFKA_REST_HOST_NAME: kafka-rest-proxy\r\n      KAFKA_REST_BOOTSTRAP_SERVERS: kafka:9092\r\n    depends_on:\r\n      - zookeeper\r\n      - kafka\r\n      - kafka-schema-registry\r\n\r\n  kafka-topics-ui:\r\n    image: landoop/kafka-topics-ui:0.9.3\r\n    hostname: kafka-topics-ui\r\n    ports:\r\n      - \"8000:8000\"\r\n    environment:\r\n      KAFKA_REST_PROXY_URL: \"http://kafka-rest-proxy:8082/\"\r\n      PROXY: \"true\"\r\n    depends_on:\r\n      - zookeeper\r\n      - kafka\r\n      - kafka-schema-registry\r\n      - kafka-rest-proxy\r\n\r\n  kafka-connect:\r\n    image: docker.optum.com/rshar45/debezium-kafka-connect-mysql\r\n    hostname: kafka-connect\r\n    ports:\r\n      - \"8083:8083\"\r\n    environment:\r\n      CONNECT_BOOTSTRAP_SERVERS: \"kafka:9092\"\r\n      CONNECT_REST_PORT: 8083\r\n      CONNECT_GROUP_ID: compose-connect-group\r\n      CONNECT_CONFIG_STORAGE_TOPIC: docker-connect-configs\r\n      CONNECT_OFFSET_STORAGE_TOPIC: docker-connect-offsets\r\n      CONNECT_STATUS_STORAGE_TOPIC: docker-connect-status\r\n      CONNECT_KEY_CONVERTER: org.apache.kafka.connect.json.JsonConverter\r\n      CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: 'http://kafka-schema-registry:8081'\r\n      CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter\r\n      CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: 'http://kafka-schema-registry:8081'\r\n      CONNECT_INTERNAL_KEY_CONVERTER: \"org.apache.kafka.connect.json.JsonConverter\"\r\n      CONNECT_INTERNAL_VALUE_CONVERTER: \"org.apache.kafka.connect.json.JsonConverter\"\r\n      CONNECT_REST_ADVERTISED_HOST_NAME: \"kafka-connect\"\r\n      CONNECT_LOG4J_ROOT_LOGLEVEL: \"INFO\"\r\n      CONNECT_LOG4J_LOGGERS: \"org.apache.kafka.connect.runtime.rest=WARN,org.reflections=ERROR\"\r\n      CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR: \"1\"\r\n      CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR: \"1\"\r\n      CONNECT_STATUS_STORAGE_REPLICATION_FACTOR: \"1\"\r\n      CONNECT_PLUGIN_PATH: '/usr/share/java,/etc/kafka-connect/jars, /usr/share/java/kafka-connect-jdbc'\r\n    depends_on:\r\n      - zookeeper\r\n      - kafka\r\n      - kafka-schema-registry\r\n      - kafka-rest-proxy\r\n\r\n  kafka-connect-ui:\r\n    image: landoop/kafka-connect-ui:0.9.4\r\n    hostname: kafka-connect-ui\r\n    ports:\r\n      - \"8003:8000\"\r\n    environment:\r\n      CONNECT_URL: \"http://kafka-connect:8083/\"\r\n      PROXY: \"true\"\r\n    depends_on:\r\n      - kafka-connect\r\n\r\n  zoonavigator-web:\r\n    image: elkozmon/zoonavigator-web:0.4.0\r\n    ports:\r\n     - \"8004:8000\"\r\n    environment:\r\n      API_HOST: \"zoonavigator-api\"\r\n      API_PORT: 9000\r\n    links:\r\n     - zoonavigator-api\r\n    depends_on:\r\n     - zoonavigator-api\r\n    restart: unless-stopped\r\n\r\n  zoonavigator-api:\r\n    image: elkozmon/zoonavigator-api:0.4.0\r\n    environment:\r\n      SERVER_HTTP_PORT: 9000\r\n    restart: unless-stopped\r\n    depends_on:\r\n      - zookeeper\r\n```\r\n\r\nLog output \r\n\r\n```\r\n15:55:36.483 [main] INFO  o.apache.kafka.streams.StreamsConfig - StreamsConfig values: \r\n\tapplication.id = ehb-transformer-service\r\n\tapplication.server = \r\n\tbootstrap.servers = [localhost:29092]\r\n\tbuffered.records.per.partition = 1000\r\n\tcache.max.bytes.buffering = 10485760\r\n\tclient.id = ehb-transformer-service-392876276-1644671345\r\n\tcommit.interval.ms = 30000\r\n\tconnections.max.idle.ms = 540000\r\n\tdefault.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler\r\n\tdefault.key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde\r\n\tdefault.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler\r\n\tdefault.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp\r\n\tdefault.value.serde = class io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tnum.standby.replicas = 0\r\n\tnum.stream.threads = 1\r\n\tpartition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper\r\n\tpoll.ms = 100\r\n\tprocessing.guarantee = at_least_once\r\n\treceive.buffer.bytes = 32768\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\treplication.factor = 1\r\n\trequest.timeout.ms = 40000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\trocksdb.config.setter = null\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tstate.cleanup.delay.ms = 600000\r\n\tstate.dir = /tmp/kafka-streams\r\n\ttopology.optimization = none\r\n\tupgrade.from = null\r\n\twindowstore.changelog.additional.retention.ms = 86400000\r\n\r\n15:55:36.585 [main] INFO  o.a.k.c.admin.AdminClientConfig - AdminClientConfig values: \r\n\tbootstrap.servers = [localhost:29092]\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-admin\r\n\tconnections.max.idle.ms = 300000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 120000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\r\n15:55:36.626 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'key.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.serde' was supplied but isn't a known config.\r\n15:55:36.627 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.serde' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.serde' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'value.serde' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.628 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.629 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka version : 2.0.0\r\n15:55:36.629 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a8361b734732\r\n15:55:36.636 [main] INFO  o.a.k.s.p.internals.StreamThread - stream-thread [ehb-transformer-service-392876276-1644671345-StreamThread-1] Creating restore consumer client\r\n15:55:36.638 [main] INFO  o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: \r\n\tauto.commit.interval.ms = 5000\r\n\tauto.offset.reset = none\r\n\tbootstrap.servers = [localhost:29092]\r\n\tcheck.crcs = true\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-StreamThread-1-restore-consumer\r\n\tconnections.max.idle.ms = 540000\r\n\tdefault.api.timeout.ms = 60000\r\n\tenable.auto.commit = false\r\n\texclude.internal.topics = true\r\n\tfetch.max.bytes = 52428800\r\n\tfetch.max.wait.ms = 500\r\n\tfetch.min.bytes = 1\r\n\tgroup.id = \r\n\theartbeat.interval.ms = 3000\r\n\tinterceptor.classes = []\r\n\tinternal.leave.group.on.close = false\r\n\tisolation.level = read_uncommitted\r\n\tkey.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\r\n\tmax.partition.fetch.bytes = 1048576\r\n\tmax.poll.interval.ms = 2147483647\r\n\tmax.poll.records = 1000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tpartition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 30000\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tsession.timeout.ms = 10000\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\tvalue.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\r\n\r\n15:55:36.705 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.serde' was supplied but isn't a known config.\r\n15:55:36.706 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.706 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.706 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.706 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.706 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'key.serializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'key.serde' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.707 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.value.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.key.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'value.serializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.serde' was supplied but isn't a known config.\r\n15:55:36.708 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.serde' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'value.serde' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.709 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.709 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka version : 2.0.0\r\n15:55:36.709 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a8361b734732\r\n15:55:36.717 [main] INFO  o.a.k.s.p.internals.StreamThread - stream-thread [ehb-transformer-service-392876276-1644671345-StreamThread-1] Creating shared producer client\r\n15:55:36.723 [main] INFO  o.a.k.c.producer.ProducerConfig - ProducerConfig values: \r\n\tacks = all\r\n\tbatch.size = 16384\r\n\tbootstrap.servers = [localhost:29092]\r\n\tbuffer.memory = 33554432\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-StreamThread-1-producer\r\n\tcompression.type = none\r\n\tconnections.max.idle.ms = 540000\r\n\tenable.idempotence = false\r\n\tinterceptor.classes = []\r\n\tkey.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\r\n\tlinger.ms = 1\r\n\tmax.block.ms = 60000\r\n\tmax.in.flight.requests.per.connection = 5\r\n\tmax.request.size = 1048576\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\r\n\treceive.buffer.bytes = 32768\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 30000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\ttransaction.timeout.ms = 60000\r\n\ttransactional.id = null\r\n\tvalue.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\r\n\r\n15:55:36.795 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.key.serde' was supplied but isn't a known config.\r\n15:55:36.797 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'value.deserializer' was supplied but isn't a known config.\r\n15:55:36.800 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.800 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'key.serde' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.801 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'key.deserializer' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.value.serde' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'default.key.serde' was supplied but isn't a known config.\r\n15:55:36.802 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.803 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.803 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.key.serde' was supplied but isn't a known config.\r\n15:55:36.804 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.804 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.804 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.value.serde' was supplied but isn't a known config.\r\n15:55:36.804 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.value.serde' was supplied but isn't a known config.\r\n15:55:36.804 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.805 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.805 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'value.serde' was supplied but isn't a known config.\r\n15:55:36.805 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.805 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'consumers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.805 [main] WARN  o.a.k.c.producer.ProducerConfig - The configuration 'producers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.806 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka version : 2.0.0\r\n15:55:36.806 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a8361b734732\r\n15:55:36.837 [main] INFO  o.a.k.s.p.internals.StreamThread - stream-thread [ehb-transformer-service-392876276-1644671345-StreamThread-1] Creating consumer client\r\n15:55:36.845 [main] INFO  o.a.k.c.admin.AdminClientConfig - AdminClientConfig values: \r\n\tbootstrap.servers = [localhost:29092]\r\n\tclient.id = ehb-transformer-service-392876276-1644671345\r\n\tconnections.max.idle.ms = 300000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 120000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\r\n15:55:36.848 [main] INFO  o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: \r\n\tauto.commit.interval.ms = 5000\r\n\tauto.offset.reset = earliest\r\n\tbootstrap.servers = [localhost:29092]\r\n\tcheck.crcs = true\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-StreamThread-1-consumer\r\n\tconnections.max.idle.ms = 540000\r\n\tdefault.api.timeout.ms = 60000\r\n\tenable.auto.commit = false\r\n\texclude.internal.topics = true\r\n\tfetch.max.bytes = 52428800\r\n\tfetch.max.wait.ms = 500\r\n\tfetch.min.bytes = 1\r\n\tgroup.id = ehb-transformer-service\r\n\theartbeat.interval.ms = 3000\r\n\tinterceptor.classes = []\r\n\tinternal.leave.group.on.close = false\r\n\tisolation.level = read_uncommitted\r\n\tkey.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\r\n\tmax.partition.fetch.bytes = 1048576\r\n\tmax.poll.interval.ms = 2147483647\r\n\tmax.poll.records = 1000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tpartition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor]\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 30000\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tsession.timeout.ms = 10000\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\tvalue.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\r\n\r\n15:55:36.864 [main] INFO  o.apache.kafka.streams.StreamsConfig - StreamsConfig values: \r\n\tapplication.id = ehb-transformer-service\r\n\tapplication.server = \r\n\tbootstrap.servers = [localhost:29092]\r\n\tbuffered.records.per.partition = 1000\r\n\tcache.max.bytes.buffering = 10485760\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-StreamThread-1-consumer\r\n\tcommit.interval.ms = 30000\r\n\tconnections.max.idle.ms = 540000\r\n\tdefault.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler\r\n\tdefault.key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde\r\n\tdefault.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler\r\n\tdefault.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp\r\n\tdefault.value.serde = class io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tnum.standby.replicas = 0\r\n\tnum.stream.threads = 1\r\n\tpartition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper\r\n\tpoll.ms = 100\r\n\tprocessing.guarantee = at_least_once\r\n\treceive.buffer.bytes = 32768\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\treplication.factor = 1\r\n\trequest.timeout.ms = 40000\r\n\tretries = 0\r\n\tretry.backoff.ms = 100\r\n\trocksdb.config.setter = null\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tstate.cleanup.delay.ms = 600000\r\n\tstate.dir = /tmp/kafka-streams\r\n\ttopology.optimization = none\r\n\tupgrade.from = null\r\n\twindowstore.changelog.additional.retention.ms = 86400000\r\n\r\n15:55:36.870 [main] INFO  o.a.k.c.admin.AdminClientConfig - AdminClientConfig values: \r\n\tbootstrap.servers = [localhost:29092]\r\n\tclient.id = dummy-admin\r\n\tconnections.max.idle.ms = 300000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 120000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\r\n15:55:36.879 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.880 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.881 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.882 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.883 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.884 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.serde' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.serde' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.value.serde' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.serde' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.key.serializer' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.serde' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.885 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'key.serializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.value.serializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'key.serde' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.serde' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'value.serializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:36.886 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'admin.retries' was supplied but isn't a known config.\r\n15:55:36.887 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'producers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:36.887 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'value.serde' was supplied but isn't a known config.\r\n15:55:36.887 [main] WARN  o.a.k.c.consumer.ConsumerConfig - The configuration 'consumers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:36.887 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka version : 2.0.0\r\n15:55:36.887 [main] INFO  o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a8361b734732\r\n15:55:37.001 [ehb-transformer-service-392876276-1644671345-StreamThread-1] INFO  o.a.k.s.p.internals.StreamThread - stream-thread [ehb-transformer-service-392876276-1644671345-StreamThread-1] Starting\r\n15:55:37.002 [ehb-transformer-service-392876276-1644671345-StreamThread-1] INFO  o.a.k.s.p.internals.StreamThread - stream-thread [ehb-transformer-service-392876276-1644671345-StreamThread-1] State transition from CREATED to RUNNING\r\n15:55:37.071 [main] INFO  o.apache.kafka.streams.KafkaStreams - stream-client [ehb-transformer-service-392876276-1644671345] Started Streams client\r\n15:55:37.074 [main] INFO  o.apache.kafka.streams.StreamsConfig - StreamsConfig values: \r\n\tapplication.id = ehb-transformer-service\r\n\tapplication.server = \r\n\tbootstrap.servers = [localhost:29092]\r\n\tbuffered.records.per.partition = 1000\r\n\tcache.max.bytes.buffering = 10485760\r\n\tclient.id = ehb-transformer-service-392876276-1644671345\r\n\tcommit.interval.ms = 30000\r\n\tconnections.max.idle.ms = 540000\r\n\tdefault.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler\r\n\tdefault.key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde\r\n\tdefault.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler\r\n\tdefault.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp\r\n\tdefault.value.serde = class io.confluent.kafka.streams.serdes.avro.GenericAvroSerde\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tnum.standby.replicas = 0\r\n\tnum.stream.threads = 1\r\n\tpartition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper\r\n\tpoll.ms = 100\r\n\tprocessing.guarantee = at_least_once\r\n\treceive.buffer.bytes = 32768\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\treplication.factor = 1\r\n\trequest.timeout.ms = 40000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\trocksdb.config.setter = null\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tstate.cleanup.delay.ms = 600000\r\n\tstate.dir = /tmp/kafka-streams\r\n\ttopology.optimization = none\r\n\tupgrade.from = null\r\n\twindowstore.changelog.additional.retention.ms = 86400000\r\n\r\n15:55:37.077 [main] INFO  o.a.k.c.admin.AdminClientConfig - AdminClientConfig values: \r\n\tbootstrap.servers = [localhost:29092]\r\n\tclient.id = ehb-transformer-service-392876276-1644671345-admin\r\n\tconnections.max.idle.ms = 300000\r\n\tmetadata.max.age.ms = 300000\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\treceive.buffer.bytes = 65536\r\n\treconnect.backoff.max.ms = 1000\r\n\treconnect.backoff.ms = 50\r\n\trequest.timeout.ms = 120000\r\n\tretries = 1\r\n\tretry.backoff.ms = 100\r\n\tsasl.client.callback.handler.class = null\r\n\tsasl.jaas.config = null\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.login.callback.handler.class = null\r\n\tsasl.login.class = null\r\n\tsasl.login.refresh.buffer.seconds = 300\r\n\tsasl.login.refresh.min.period.seconds = 60\r\n\tsasl.login.refresh.window.factor = 0.8\r\n\tsasl.login.refresh.window.jitter = 0.05\r\n\tsasl.mechanism = GSSAPI\r\n\tsecurity.protocol = PLAINTEXT\r\n\tsend.buffer.bytes = 131072\r\n\tssl.cipher.suites = null\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = https\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\r\n15:55:37.084 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.serde' was supplied but isn't a known config.\r\n15:55:37.084 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.deserializer' was supplied but isn't a known config.\r\n15:55:37.084 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.deserializer' was supplied but isn't a known config.\r\n15:55:37.084 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.serializer' was supplied but isn't a known config.\r\n15:55:37.085 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.\r\n15:55:37.085 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.serializer' was supplied but isn't a known config.\r\n15:55:37.085 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.key.serializer' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'key.serde' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.serde' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.serializer' was supplied but isn't a known config.\r\n15:55:37.086 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.serde' was supplied but isn't a known config.\r\n15:55:37.087 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.deserializer' was supplied but isn't a known config.\r\n15:55:37.088 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.serde' was supplied but isn't a known config.\r\n15:55:37.088 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.serde' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.value.deserializer' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.value.serde' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.value.serde' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.serde' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.default.key.deserializer' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'value.serde' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.deserializer' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'consumers.default.key.serializer' was supplied but isn't a known config.\r\n15:55:37.089 [main] WARN  o.a.k.c.admin.AdminClientConfig - The configuration 'producers.key.serializer' was supplied but isn't a known config.\r\n```"},"comment":{"url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/comments/434477169","html_url":"https://github.com/micronaut-projects/micronaut-core/issues/812#issuecomment-434477169","issue_url":"https://api.github.com/repos/micronaut-projects/micronaut-core/issues/812","id":434477169,"node_id":"MDEyOklzc3VlQ29tbWVudDQzNDQ3NzE2OQ==","user":{"login":"ctoestreich","id":691357,"node_id":"MDQ6VXNlcjY5MTM1Nw==","avatar_url":"https://avatars3.githubusercontent.com/u/691357?v=4","gravatar_id":"","url":"https://api.github.com/users/ctoestreich","html_url":"https://github.com/ctoestreich","followers_url":"https://api.github.com/users/ctoestreich/followers","following_url":"https://api.github.com/users/ctoestreich/following{/other_user}","gists_url":"https://api.github.com/users/ctoestreich/gists{/gist_id}","starred_url":"https://api.github.com/users/ctoestreich/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ctoestreich/subscriptions","organizations_url":"https://api.github.com/users/ctoestreich/orgs","repos_url":"https://api.github.com/users/ctoestreich/repos","events_url":"https://api.github.com/users/ctoestreich/events{/privacy}","received_events_url":"https://api.github.com/users/ctoestreich/received_events","type":"User","site_admin":false},"created_at":"2018-10-30T21:30:05Z","updated_at":"2018-10-30T21:30:05Z","author_association":"CONTRIBUTOR","body":"Closing until I can produce example project as this appears to actually be replated to the @SendTo annotation."}}
{"actor":{"display_login":"ctoestreich"}}