You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Jamie Brandon (Jira)" <ji...@apache.org> on 2021/04/01 00:42:00 UTC
[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and
prevents other streams from producing output
[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312797#comment-17312797 ]
Jamie Brandon commented on KAFKA-12594:
---------------------------------------
Slack discussion - https://confluentcommunity.slack.com/archives/C48AHTCUQ/p1617235296411100
> 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
>
> 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)