Make value_sanitizer an argument of JournalWriter.
Instead of being a method of KafkaJournalWriter.
This will allow using JournalWriters for values that aren't model objects.
Description
Description
Details
Details
- Provenance
vlorentz Authored on Sep 29 2020, 3:06 PM vlorentz Pushed on Nov 2 2020, 12:41 PM - Differential Revision
- D4080: Make value_sanitizer an argument of JournalWriter.
- Tasks
- T2651: Make the indexer-storage publish its rows to Kafka
- Build Status
Buildable 16785 Build 25878: test-and-build Jenkins console · Jenkins