-
Notifications
You must be signed in to change notification settings - Fork 217
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
Schema-registry integration #593
Conversation
a0fbe68
to
016b344
Compare
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 🏆
9f1e3f9
to
330b1ae
Compare
330b1ae
to
51b9896
Compare
|
||
import java.util.Optional; | ||
|
||
import static pl.allegro.tech.hermes.api.ContentType.AVRO; | ||
import static pl.allegro.tech.hermes.api.TopicName.fromQualifiedName; | ||
|
||
@Component | ||
public class SchemaSourceService { |
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.
i wonder - we use term schema source
everywhere and i don't know if it's a proper one - schema source sounds like source of schema aka schema repository, while what we mean is schema itself (aka raw schema in text format). Maybe it's a good time to change this?
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.
Agreed, I'll rename it to RawSchema
.
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.
Renaming done.
@@ -0,0 +1,240 @@ | |||
package pl.allegro.tech.hermes.schema.schemarepo; |
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.
why is it in java and not groovy? this is weird, as other tests are in groovy in this module
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.
I've been reusing old tests, transforming them to groovy shouldn't take long. :)
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.
OK, all hermes-schema
tests are now groovy :)
I'm mostly confused with the naming, but all in all - good job :) |
This PR introduces support for Confluent Schema Registry as the next default Avro schema repository.
Important changes:
hermes-console
) - from now on schemas are supported for Avro topics onlyhermes-schema
module for schema-related content (note: DI-factory classes, Avro message wrappers / SerDe are left inhermes-common
)