[ https://issues.apache.org/jira/browse/KAFKA-13977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
jeff-qiu resolved KAFKA-13977. ------------------------------ Resolution: Not A Problem sorry about it,this is not a kafka problem. > 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 > Priority: Minor > Labels: beginner > 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)