| .. |
|
client.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 vuotta sitten |
|
consumer.go
|
075f516a2e
Tweaks
|
12 vuotta sitten |
|
errors.go
|
1195e7f8d1
More cleanup, reorg, API tweaks
|
12 vuotta sitten |
|
kafka.go
|
9047579808
Split into two packages, one low-level, one high
|
12 vuotta sitten |
|
message.go
|
362314c5bc
Really basic, hacky consumer implementation
|
12 vuotta sitten |
|
metadata_cache.go
|
bf6925bd05
Fix two metadata-cache bugs
|
12 vuotta sitten |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 vuotta sitten |
|
producer.go
|
e2d6d53bb6
Simplify producer API, no need to add options until we actually need them
|
12 vuotta sitten |
|
utils.go
|
9c71ad5039
Fewer producer helper functions, just make StringEncoder public
|
12 vuotta sitten |
Evan Huus
075f516a2e
Tweaks