100644 blob e69a9b21fe92bba1e8b5412106f17a671bd7022a	client.go
100644 blob d45253d57f0ee92809de735cdc40ecc312343a67	consumer.go
100644 blob 8b73a95fc9702db30686bf9be429018e89a38fb8	error.go
100644 blob b73080b80c2c1ef8a446a10a5d2fd9e7423473f0	impl_client.go
100644 blob ec3110afa1ab0055f675c7ea1870e14edd8caf15	impl_client_test.go
100644 blob a7b12077d98f2ff4eb4bd866910bb3c0c01e09ad	impl_message.go
100644 blob bd484953018745d90d1c170502f7a6fb8caea29d	impl_message_test.go
100644 blob ce8a2a965aeb5a90644a659abd728f8c994bbc7b	impl_partition_producer.go
100644 blob 497a18c0f146c476138ba06d2dd69645c20828d8	impl_producer.go
040000 tree 55453b56ffc4a1e77c3d55e6691794360f371f02	internal
100644 blob 1862c18230453ad44a8288c6f584be25a0eeae9f	message.go
100644 blob c77a047720d2d15cd620527f6bacc1049b72d6e3	producer.go
100644 blob 0b17b37e3f2fe0981977512ccad1527726e835ff	producer_test.go
100644 blob 3e088b4e90d5a842f383a3521703fcddf330f6e4	reader.go
100644 blob c58c239906bdc809e46259f01122427e0c8b30f6	test_helper.go