You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "jeff-qiu (Jira)" <ji...@apache.org> on 2022/06/13 01:22:00 UTC

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

     [ 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)