Skip to content

KAFKA-2484: Add schema projection utilities#307

Closed
Ishiihara wants to merge 3 commits into
apache:trunkfrom
Ishiihara:schema-projection
Closed

KAFKA-2484: Add schema projection utilities#307
Ishiihara wants to merge 3 commits into
apache:trunkfrom
Ishiihara:schema-projection

Conversation

@Ishiihara

Copy link
Copy Markdown
Contributor

This PR adds schema projection utilities to copycat.

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can we fill in a regular javadoc description. It'll probably be similar to the one on the class.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Done.

@Ishiihara

Copy link
Copy Markdown
Contributor Author

@ewencp Addressed the review comments and updated the PR. Please take a look when you have time.

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If the record is null, this isn't doing any schema compatibility checks besides the check for optional/required check at the top of this method. This is causing the logical type test to fail.

@Ishiihara

Copy link
Copy Markdown
Contributor Author

@ewencp Update PR according to your review comments.

@ewencp

ewencp commented Oct 16, 2015

Copy link
Copy Markdown
Contributor

Looks good. @gwenshap care to review & commit?

@gwenshap

Copy link
Copy Markdown
Contributor

Looks great! Thanks @Ishiihara and @ewencp

@asfgit asfgit closed this in ef65d0a Oct 16, 2015
@Ishiihara
Ishiihara deleted the schema-projection branch March 31, 2016 23:23
efeg pushed a commit to efeg/kafka that referenced this pull request Jan 29, 2020
hachikuji added a commit to hachikuji/kafka that referenced this pull request May 6, 2020
This patch makes the following improvements:

1. Replace the usage of `requestId` with `correlationId`, which is already widely used in Kafka.
2. Make `MockLog` aware of record batching to make its behavior more consistent with the `Log` implementation and to 
3. Add test coverage to `ConnectionCache`.
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