Closed dipinhora closed 6 years ago
Sadly, too much stuff got intermingled so this is one huge commit instead of logically separated commits of things. 8*/
Includes:
iso
this
conn
KafkaMessage
KafkaMessageMetadata
Sadly, too much stuff got intermingled so this is one huge commit instead of logically separated commits of things. 8*/
Includes:
iso
for consumersthis
instead ofconn
)KafkaMessage
class and replace with iso array for value, val array or None for key, andKafkaMessageMetadata
for metadata