[
https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051482#comment-17051482
]
Paul Snively commented on KAFKA-9636:
-------------------------------------
John,
I've attached what I believe is a more legible version of the test, in case
that helps.
Unfortunately, at this stage, I'm really stuck. What I have is:
* A test that generates a `Topology` with a simple foreign-key join of 2
(currently hardcoded) `KTable`s.
* Generates 2 records, the first of which has a foreign-key reference to the
second.
* Sends the records to their respective `TestInputTopic`s with the correct
keys.
* Nondeterministically, sooner or later, results in an empty `TestOutputTopic`.
I suppose I'm still prepared to believe I'm doing something wrong, but I have
to admit it's extremely difficult to see how that's possible.
> Simple join of two KTables fails
> --------------------------------
>
> Key: KAFKA-9636
> URL: https://issues.apache.org/jira/browse/KAFKA-9636
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.4.1
> Reporter: Paul Snively
> Priority: Major
> Attachments: kafka.tar.xz, merge_issue.zip, merge_issue.zip,
> merge_issue.zip, merge_issue.zip
>
>
> Attempting to join two KTables yields a `Topology` that, when tested with
> `TopologyTestDriver` by adding records to the two `TestInputTopic`s, results
> in an empty `TestOutputTopic`.
> I'm attaching a very small reproduction. The code is in Scala. The project is
> therefore an "sbt" project. You can reproduce the results from your shell
> with `sbt test`. The failure output will include the `describe` of the
> `Topology` in question.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
