Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: proposal to let the API Key READ and WRITE the content of the r… #37

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

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