RecordFormatter¶
Creating Instance¶
RecordFormatter takes the following to be created:
-
SchemaRegistryClient - Topic Name
RecordFormatter is created when:
PrintPublisheris requested tosubscribe(to create aPrintSubscription)TopicStreamWriteris requested towrite(to create aPrintSubscription)
format¶
List<String> format(
Iterable<ConsumerRecord<Bytes, Bytes>> records)
format...FIXME
format is used when:
PrintSubscriptionis requested topollTopicStreamWriteris requested towrite