produce_request_test.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package protocol
  2. import "testing"
  3. import "sarama/types"
  4. var (
  5. produceRequestEmpty = []byte{
  6. 0x00, 0x00,
  7. 0x00, 0x00, 0x00, 0x00,
  8. 0x00, 0x00, 0x00, 0x00}
  9. produceRequestHeader = []byte{
  10. 0x01, 0x23,
  11. 0x00, 0x00, 0x04, 0x44,
  12. 0x00, 0x00, 0x00, 0x00}
  13. produceRequestOneMessage = []byte{
  14. 0x01, 0x23,
  15. 0x00, 0x00, 0x04, 0x44,
  16. 0x00, 0x00, 0x00, 0x01,
  17. 0x00, 0x05, 't', 'o', 'p', 'i', 'c',
  18. 0x00, 0x00, 0x00, 0x01,
  19. 0x00, 0x00, 0x00, 0xAD,
  20. 0x00, 0x00, 0x00, 0x1C,
  21. // messageSet
  22. 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
  23. 0x00, 0x00, 0x00, 0x10,
  24. // message
  25. 0x23, 0x96, 0x4a, 0xf7, // CRC
  26. 0x00,
  27. 0x00,
  28. 0xFF, 0xFF, 0xFF, 0xFF,
  29. 0x00, 0x00, 0x00, 0x02, 0x00, 0xEE}
  30. )
  31. func TestProduceRequest(t *testing.T) {
  32. request := new(ProduceRequest)
  33. testEncodable(t, "empty", request, produceRequestEmpty)
  34. request.RequiredAcks = 0x123
  35. request.Timeout = 0x444
  36. testEncodable(t, "header", request, produceRequestHeader)
  37. request.AddMessage("topic", 0xAD, &Message{Codec: types.COMPRESSION_NONE, Key: nil, Value: []byte{0x00, 0xEE}})
  38. testEncodable(t, "one message", request, produceRequestOneMessage)
  39. }