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)
