kafka 0.2.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

# Index

* fetch1.txt
  - the input to various topic set-ups
  - 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
  - the fetch response data (omit 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
  - the fetch response data (omit 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
  - the fetch response data (omit 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