[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313504#comment-17313504 ]
Jamie Brandon commented on KAFKA-12594: --------------------------------------- Btw the repo at https://github.com/jamii/streaming-consistency/tree/main/kafka-streams should be easy to repro on any linux machine and only depends on nix. > Self-join produces no ouput, and prevents other streams from producing output > ----------------------------------------------------------------------------- > > Key: KAFKA-12594 > URL: https://issues.apache.org/jira/browse/KAFKA-12594 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.7.0 > Environment: > https://github.com/jamii/streaming-consistency/blob/c1f504e73141405ee6cd0c7f217604d643babf81/pkgs.nix > [nix-shell:~/streaming-consistency/kafka-streams]$ java -version > openjdk version "1.8.0_265" > OpenJDK Runtime Environment (build 1.8.0_265-ga) > OpenJDK 64-Bit Server VM (build 25.265-bga, mixed mode) > [nix-shell:~/streaming-consistency/kafka-streams]$ nix-info > system: "x86_64-linux", multi-user?: yes, version: nix-env (Nix) 2.3.10, > channels(jamie): "", channels(root): "nixos-20.09.3554.f8929dce13e", nixpkgs: > /nix/var/nix/profiles/per-user/root/channels/nixos > Reporter: Jamie Brandon > Priority: Major > Attachments: logs.tar.gz > > > I have a simple kafka-streams example which just reads in some transactions > and writes them back out again. > https://github.com/jamii/streaming-consistency/blob/c1f504e73141405ee6cd0c7f217604d643babf81/kafka-streams/src/main/java/Demo.java > This works fine and I see the right output in 'accepted_transactions'. > If I uncomment the left join at line 58, then not only do I not get any > output for the left join, but I don't get any output in > 'accepted_transactions' either. -- This message was sent by Atlassian Jira (v8.3.4#803005)