Skip to content

Conversation

@mavomo
Copy link

@mavomo mavomo commented Nov 18, 2024

…ecently created topics

@mavomo mavomo requested a review from a team as a code owner November 18, 2024 15:47
@confluent-cla-assistant
Copy link

❌ Error getting contributor login(s).
Please ensure the email address associated with this commit is [added to your Github account].(https://docs.github.com/en/pull-requests/committing-changes-to-your-project/troubleshooting-commits/why-are-my-commits-linked-to-the-wrong-user#commits-are-not-linked-to-any-user)

@davetroiano
Copy link

@mavomo I ran through the module and didn't run into a permissions issue that needed this. Could you try moving src/main/java/io/confluent/developer/basic/solution/BasicStreams.java to src/main/java/io/confluent/developer/basic/BasicStreams.java and changing the package to package io.confluent.developer.basic;, and then report back on whether that worked? That was my repro but I do get the expected output:

% ./gradlew runStreams -Pargs=basic


> Configure project :
Using example io.confluent.developer.basic.BasicStreams

> Task :runStreams
Record produced - offset - 0 timestamp - 1731964767837
Record produced - offset - 1 timestamp - 1731964767858
Record produced - offset - 2 timestamp - 1731964767859
Record produced - offset - 3 timestamp - 1731964767859
Record produced - offset - 4 timestamp - 1731964767859
Record produced - offset - 5 timestamp - 1731964767859
Record produced - offset - 6 timestamp - 1731964767859
Incoming record - key order-key value orderNumber-1001
Outgoing record - key order-key value 1001
Incoming record - key order-key value orderNumber-5000
Outgoing record - key order-key value 5000
Incoming record - key order-key value orderNumber-999
Incoming record - key order-key value orderNumber-3330
Outgoing record - key order-key value 3330
Incoming record - key order-key value bogus-1
Incoming record - key order-key value bogus-2
Incoming record - key order-key value orderNumber-8400
Outgoing record - key order-key value 8400

If you're still running into issues could you also please share your src/main/resources/streams.properties file with any API keys replaced with placeholders

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants