ruby-kafka-0.1.6

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899421

number: 0.1.6

platform: ruby

spec_sha256: 79fbc4a7785fba51c845c1b74e6f34ebbfc998fa2523c81ec200119e3563b685

sha256: 53b867a7a46664ef6fe3b29715e4891399d70d79df75fda4f844ce38dce51405

created_at: 2024-05-13 08:27:35 UTC

updated_at: 2024-06-11 10:05:21 UTC

position: 99

version_data_entries_count: 48

uploaded_at: 2016-02-22 14:21:05 UTC

indexed: true

has_extensions:

extensions:

Gem size: 34.5 KB

Version Data Entries

Total: 48

Unpacked size: 109 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.gitignore1006440092 Bytes47b9710cb343396e1c3daa8fd99f530f37e0d5ac5c4cacfacb2632cc3e43c981
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
Gemfile1006440052 Bytes42796cc19af6cf22b7bbeef298a74d1f66d358bd73f7eb194df56c652f2dd846
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
README.md1006440015.2 KBe661af6df2336e8ff977ec6123e40634ce60fff01f94f2b09e6745b8f2a22f8e
Rakefile10064400114 Bytesd0726d260349476762de87bdd5c451c7bfe6e0e47fe09df9f011e120f1fd316b
bin/console1007550086 Bytes6e7cdf8cdc22cf29f16f4261589138eb0cd4e9f88a018adf9767c797fba13b38
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
circle.yml1006440047 Bytesf052d001c6f7985c07504c5bd2d2357c110a7ea2d75d704d78b2ea3e14efa9fb
examples/simple-consumer.rb100644001.02 KB8525a99dcb507aa29f28602cc74967ba0f740d5d0e205b6046ed101a790ecf39
examples/simple-producer.rb10064400875 Bytes031f0602b0fea22476c8ece62c63f0db6e2c83213bb134167ecd57f11b3b463e
lib/kafka.rb100644003.22 KBbd85a7c5157e199101b8873aed5791c270efda586582d71fd318f9930b217182
lib/kafka/async_producer.rb100644005.37 KBeb076e0fb9aebf09bb9fb8241060df8ca3a3362274bb3e7892f25b8502dea0e1
lib/kafka/broker.rb100644001.82 KB120d765bc20cd0b3ffb18a437077535f35f8af9421102259f8cdeedf51e66b60
lib/kafka/broker_pool.rb10064400882 Bytesbd6aba181494bd1f5d26cf864fef9d3843cafdc02fc769e4e7995e54b6518a74
lib/kafka/client.rb100644005.16 KBb7ed3dcadac53b5ec2604eaa53c052931e7883ed6cc3d6c295fe834315ac7d94
lib/kafka/cluster.rb100644003.66 KBb5b4d067e41a048a5ff5e4ed12566ef9010b37443aef73e829fc83a641caf8a5
lib/kafka/compression.rb10064400511 Bytes369b220690094ec1eeb5dcf09a89810d4c1c55c52e22e8c7286f03040ccde4c9
lib/kafka/connection.rb100644006.09 KB3006e5f9d4d8e199ccf281670a32d814cbf6cccfa43a579ba9e5c067069e2023
lib/kafka/fetch_operation.rb100644003.48 KBd3467b494270c1271ea0d885fb50fc7835b14e5d5afce03d6c4d4b719748be15
lib/kafka/fetched_message.rb10064400671 Bytesd45ba1cdf452f7a35ad1017cffad9a29276ce0cf1999ea9f6648be45b6c32a11
lib/kafka/gzip_codec.rb10064400518 Bytesb5ab2624e25615cd2a72c968f7a14dc70cc9db0aa5a7b9622d5b3c86746e5905
lib/kafka/instrumentation.rb10064400290 Bytesfe25fbfb397d1c4c9650010262a1a328854ce6424c64c934fe0dd1a3a9b733b8
lib/kafka/message_buffer.rb100644001.59 KB918ec076f4f4e57d5d7d4a50da5c4b66e7b66f16e0d147840b90c38fbc545321
lib/kafka/partitioner.rb100644001.08 KB5c235bfc316a6e67576af91f05d8f83e7c810feabb9f8e0045fe93384f9832c7
lib/kafka/pending_message.rb10064400314 Bytes16d3058ee424da0ba702db81249ddaa59f171ba09153a2173e54f51285de37b9
lib/kafka/produce_operation.rb100644005.51 KB67c1ab63a22b84ca23fe3afa65101ba9f231af42a70757203b87d3e2f7275193
lib/kafka/producer.rb1006440010.7 KB48739a55a77fd5c7ea55273e8bc3476c61210989a86957d4f591a54d21f2ba62
lib/kafka/protocol.rb100644001.42 KB3e9c2d4128a25ff830e425e649ad2f7656e80d657a21785e1bd514aa13c5358f
lib/kafka/protocol/decoder.rb100644002.18 KB4ab498120cf16d44e21e249f27ba3cee8a14a30473356a89b91075e2db007360
lib/kafka/protocol/encoder.rb100644002.49 KBd983fc93d169cee5444e23a8af92c36f7d2bad07568504118e223cf1aba55fa4
lib/kafka/protocol/fetch_request.rb100644001.46 KB9da02fa8536df9323b281559bdf5ceb4ee45876c8bdf47613f721a81d22a7683
lib/kafka/protocol/fetch_response.rb100644001.91 KBd6c793199f9a66b6a2fa492f558465fcd5a6ac4ffffcec02ee9246814b28a16e
lib/kafka/protocol/list_offset_request.rb100644001.1 KBaa27cf66d3dd31f59ff39ac5437efeb8d33bd742f26606de444ead90095783da
lib/kafka/protocol/list_offset_response.rb100644001.97 KBf122d94de9d3f75e91bc0f94aef41a4ee592a411c29f1aec547c709bfea2702d
lib/kafka/protocol/message.rb100644002.34 KB665ec0ace9f149e4eeb6c373292b89d8dc15b8fa7f46caa720981f74d2469ef8
lib/kafka/protocol/message_set.rb100644001.59 KBcc04de7bb5f02fb5266231dd06ff21e0497c7842f89a0ac5d2439bf82369b5a8
lib/kafka/protocol/metadata_response.rb100644005.33 KB01f36dd9ea64fcd80dffcd55d8ab219a394dcfd024b9840dfb347e490067b42e
lib/kafka/protocol/produce_request.rb100644002.29 KB3dd7d6903e14f2a9935dbcaa394eefaa3e5a64773d6cb8c8b3c9714dfcedd633
lib/kafka/protocol/produce_response.rb100644001.22 KB69dcc25b6458713bb693e77f92706ffaa44c05824d5b297a337d61ef9042be56
lib/kafka/protocol/request_message.rb10064400601 Bytes5c882647f314c7a8bde4a7cfbc15d10fe7e87e2d6eb615b562b384790c0d7d33
lib/kafka/protocol/topic_metadata_request.rb10064400458 Bytesa86e03eba101531b12c2e25dfa213902399389c2eb51d268418b811a5037483f
lib/kafka/snappy_codec.rb10064400292 Bytesf58ece1a2d34df08cc39c20491e79c94b0ed54c0d8d27e953636cf3e6e76977f
lib/kafka/socket_with_timeout.rb100644002.74 KB1f042184092505f61a929d1f5f2a19e5d6f5cf9a305e7aebba37e1cbd8a3ca18
lib/kafka/version.rb1006440037 Bytes66b74441728d191c0b534c47f00a5ec66369361fb2511a3c4f867bb654a3977f
lib/ruby-kafka.rb1006440073 Bytes824f3c16fb05879c1c499308503433e3d2758fcb86db251432eddb9ea4e29fb6
ruby-kafka.gemspec100644001.42 KBf9a22252fd6daa33acaa0a8bbe1f66eaff65a3534d3c301e05017b048f3903df