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