[jira] [Created] (KAFKA-13977) internal topic deserialize failed

["jeff-qiu (Jira)" <ji...@apache.org>]

jeff-qiu created KAFKA-13977:
--------------------------------

             Summary: internal topic deserialize failed
                 Key: KAFKA-13977
                 URL: https://issues.apache.org/jira/browse/KAFKA-13977
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 3.1.1
         Environment: version: "3"
services:
  zookeeper:
    image: 'bitnami/zookeeper:latest'
    ports:
      - '2181:2181'
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka:
    image: 'bitnami/kafka:3.1'
    ports:
      - '9092:9092'
    environment:
      - KAFKA_BROKER_ID=1
      - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092
      - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper
            Reporter: jeff-qiu
         Attachments: ApplianceOrder.java, CombinedOrder.java, ElectronicOrder.java, MyDeserializer.java, MySerializer.java, StreamsJoin.java, StreamsUtils.java, TopicLoader.java, User.java, kafka_streams_course.log

I have built my own kafka stream joining example from the code：
https://github.com/confluentinc/learn-kafka-courses/tree/main/kafka-streams/src/main/java/io/confluent/developer/joins，
the diffenrence is that I use my customed serializer and deserialized without schema registry，but it doesn't works，I found out that two streams joining will auto create an internal topic ，like joining-streams-3-KSTREAM-JOINOTHER-0000000012-store-changelog，but they can't deserialize successfully with my own deserializer。



--
This message was sent by Atlassian Jira
(v8.20.7#820007)