-
Notifications
You must be signed in to change notification settings - Fork 12
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
Pekko migration #17
Pekko migration #17
Conversation
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatter.scala
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks - a really good start - just a couple of nits
Could you look at the broken docs build when you get a chance? Probably mainly due to akka package names still used ins some .md files. |
core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala
Outdated
Show resolved
Hide resolved
Could you fix the conflict in tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala ? You'll need to merge in the recent commit to main branch and then tidy up the conflicted code. This class was probably moved because of a package name change |
There are failing integration tests because they try to use the class akka.kafka.tests.CapturingAppender - this class is now presumably renamed (package name change) |
…ala files - Added temporary copy & paste class from alpakka (till migration completes)
2b1c77e
to
db626e7
Compare
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/AlpakkaCommittableProducer.scala
Outdated
Show resolved
Hide resolved
…e_url configuration - Adjusted pekko extref links
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm - thanks
Merged - @Seetaramayya has an iCLA on file |
Using
pekko
librariesMigrated from
akka
toorg.apache.pekko
packageInstead of removing dependency on
akka-stream-alpakka-csv
library one class needs to be copy pastedIssue#20 is added to handle reference.conf and docs