THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/** ********* Broker-side Observer Configuration ****************/ val ObserverClassProp = "brokerobserver.class.observername" |
For example, with this interface and the given type of RequestChannel.Request and AbstractResponse, the information we can extract from every produce or fetch request is:
...