THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
KafkaConsumer:
Subscription => TopicList UserData AssignedPartitions
TopicList => List<String>
UserData => Bytes
AssignedPartitions => List<String, List<Int32>> // new field
Assignment = AssignedPartitions UserData RevokedPartitions ErrorCode
AssignedPartitions => List<String, List<Int32>>
UserData => Bytes
ErrorCode => Int16 // new field |
...