Repository navigation
Upgrade to Kafka 4.4 - #497
philipp94831 wants to merge 5 commits into
Conversation
|
@copilot implement tests for the new methods. See KStreamXTest for examples. There are already tests using GlobalKTable which you can adapt from |
Co-authored-by: philipp94831 <2177801+philipp94831@users.noreply.github.com>
Added tests for all four |
| }; | ||
| try (final TestTopology<String, String> topology = app.startApp()) { | ||
| topology.input("table_input") | ||
| .add("bar", "baz"); |
There was a problem hiding this comment.
@copilot Can you use four different values for the input keys and values? foo, bar, baz, qux. Also below
There was a problem hiding this comment.
Updated all four overload tests to distinguish the stream key (foo), stream value (bar), mapped table key (baz), and table value (qux). Commit: 8e1c32a. The focused test task remains blocked before compilation by unavailable Maven dependencies.
There was a problem hiding this comment.
@copilot Sorry, I didn't understand the api properly. Revert the last commit, the test was fine
There was a problem hiding this comment.
Reverted the last commit; the tests are restored to their prior values. Commit: 89745a9.
Co-authored-by: philipp94831 <2177801+philipp94831@users.noreply.github.com>
Co-authored-by: philipp94831 <2177801+philipp94831@users.noreply.github.com>
|
No description provided.