100644 blob 914793901a051093c3623ff5238e1f64eb96d4f2	client.go
100644 blob b32e5fcf36935a91eee553fbc1547877aa1e3d75	consumer.go
100644 blob 38b9d6427684f2262776b33b0edfe000dfb60024	error.go
100644 blob 0452ad4b2b9e79cffa0f719363f69ecda9670d33	impl_client.go
100644 blob 63fa6baf73555f3fd5d72f9389a1d5c7a298c019	impl_client_test.go
100644 blob 710913e7a8a39d2535f333084e0d6773fe121250	impl_message.go
100644 blob bfbfde4d8ea93767cd6f30cc293e8fa4474aec2d	impl_message_test.go
100644 blob bd112da6b44033384c9abf89473a1a3bec3fc55f	impl_partition_producer.go
100644 blob 3999ff122e9ebc594c38d6724ba97e8c29bcdde0	impl_producer.go
040000 tree 174c6b4ee0d560b1a79fde505590e2ef9aa18938	internal
100644 blob 2d03a3149b497df1fb5153dbb4f239428530140b	message.go
100644 blob 2a248cb8f9fc3924712d5e4114632d3d5928a647	producer.go
100644 blob 5ef6d2c4ba6394d0e04bc14cd00ff1cfbfe1c4f8	producer_test.go
100644 blob 55926303b41c901e456bcdf7fdff6d7615dfec3f	reader.go
100644 blob a12a989865173eb2c1e313e1f0f2d8d778c84512	test_helper.go