Skip to content
This repository was archived by the owner on Nov 20, 2024. It is now read-only.
This repository was archived by the owner on Nov 20, 2024. It is now read-only.

Unable to start spring boot application when using KTable as output , KStream as output and KTable as Input  #1237

@rameshmandri

Description

@rameshmandri

Issue with Producing KTable Output

I am encountering issues with producing KTable outputs and have tried two approaches:

Using KTable as Output and Reading It as Input: getting error : java.lang.ClassCastException: class jdk.proxy2.$Proxy217 cannot be cast to class org.apache.kafka.kstream.KTable

Using KStream as Output and Reading It as KTable Input: getting error : Caused by: java.lang.ClassCastException: class org.apache.kafka.streams.kstream.internals.KStreamImpl cannot be cast to class org.apache.kafka.streams.kstream.KTable

if I change function return type from KTable to KStream for both input and output working without any issues (note: just changed the binder to kstreamBinder in cofnig for input and output , for KTable used ktableBinder)

Environment:

Spring Boot: 3.3.2
Spring Cloud Binder: 4.1.3

I have noticed that others have also experienced similar issues in the past:

GitHub Issue #1085
GitHub Pull Request #1105

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions