kafkang 0.3.0

Rust client for Apache Kafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

# Index

- fetch1.txt
  - the input to various topic setups
  - one message per line
- fetch1.snappy.chunked.4k
  - snappy compressed fetch1.txt using SnappyOutputStream (snappy-java)
  - chunk size 4096
- fetch1.mytopic.1p.nocompression.kafka.0821
  - fetch response data (omitting the leading 4 byte size field)
  - snapshot from a 0.8.2.1 kafka server
  - input records: fetch1.txt
  - topic: "my-topic"
  - partitions: 1
  - messages were sent to the topic without any compression
- fetch1.mytopic.1p.snappy.kafka.0821
  - fetch response data (omitting the leading 4 byte size field)
  - snapshot from a 0.8.2.1 kafka server
  - input records: fetch1.txt
  - topic: "my-topic"
  - partitions: 1
  - messages were sent to the topic compressed using snappy compression
- fetch1.mytopic.1p.snappy.kafka.0822
  - fetch response data (omitting the leading 4 byte size field)
  - snapshot from a 0.8.2.2 kafka server
  - input records: fetch1.txt
  - topic: "my-topic"
  - partitions: 1
  - messages were sent to the topic compressed using snappy compression

- fetch2.txt
  - the input to various topic setups
  - exactly message only; one line
- fetch2.mytopic.nocompression.kafka.0900
  - fetch response data (omitting the leading 4 byte size field)
  - snapshot from a 0.9.0.0 kafka server
  - input records: fetch2.txt
  - topic: "my-topic"
  - partitions: 1
  - messages where sent to the topic in clear test (no compression)
- fetch2.mytopic.nocompression.invalid_crc.kafka.0900
  - same as fetch2.mytopic.nocompression.kafka.0900 except with a
    modified crc field, such that it does _not_ correspond to the
    message's data