learn-kafka-courses
learn-kafka-courses copied to clipboard
feat: proposal to let the API Key READ and WRITE the content of the r…
…ecently created topics
:x: 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)
@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