Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Permit setting version on mock produce response
This allows setting the version of the message data struct for MockProduceResponse. This change is very similar to what was already done in pull request IBM#939 In order to mock a "produce" request for Kafka version 0.10.2.0 you would use the following: leader.SetHandlerByMap(map[string]MockResponse{ "ProduceRequest": NewMockProduceResponse(t). SetVersion(2). SetError("my_topic", 0, ErrNoError), })
- Loading branch information