[KAFKA-12594] Various simple examples produce no ouput, and prevent other streams from producing output

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.7.0
• Component/s: streams

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

• Assignee: Unassigned
• Reporter: Jamie Brandon
• Created: 31/Mar/21 23:13
• Updated: 13/Apr/21 19:22

Description

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.