|
|
|
|
|
|
by lacksconfidence
3438 days ago
|
|
|
You could provide them manually, but then any schema upgrade becomes a big pain. Wikimedia, as one example, uses versioned schemas. As such each version is immutable and can be pulled from the cache. Each kafka message has a null byte, and then a long version number prefixed to indicate how it should be decoded. https://github.com/wikimedia/analytics-refinery-source/blob/... |
|
|