ruby-kafka-0.5.0.beta4

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899462

number: 0.5.0.beta4

platform: ruby

spec_sha256: e0e0e93432f81d5a026448c189261f483ae94d483decb43a6257775bb7acdc8c

sha256: f668ac1d220d7af6701fdca0c5e15d9d94123050f3ee8fb2863351b14538fb4d

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

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

position: 59

version_data_entries_count: 106

uploaded_at: 2017-10-26 08:51:54 UTC

indexed: true

has_extensions:

extensions:

Gem size: 74.5 KB

Version Data Entries

Total: 106

Unpacked size: 276 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.gitignore10064400104 Bytesd7d42fff0538e1c089ce94148a5c59a50d4557246d72209feb58d5e58b8a26da
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644003.68 KBfcfa5fd95b1f6e0936f486e58d9ef50c73365546ea88e37fa250f32147b8bdb0
Gemfile1006440039 Bytesafe937ae0b605332cd5f9bfbd40d488faff2b9cd5bdd2a6f75fb3107704a196f
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440055.8 KB2963f89181c26ab902e54693e6c6734dc151970336a6b9908084b968f802d6d9
Rakefile10064400114 Bytesd0726d260349476762de87bdd5c451c7bfe6e0e47fe09df9f011e120f1fd316b
bin/console1007550086 Bytes6e7cdf8cdc22cf29f16f4261589138eb0cd4e9f88a018adf9767c797fba13b38
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
ci/consumer.rb10064400347 Bytesbaf3e625ff8879df692c616e1d6531adf78364ac85e3cf5f40c0c486dbdd3806
ci/init.rb10064400465 Bytesa124304de5a34bd8df621223b545b843abdf55ff5f36bdf47c224a8a848e249f
ci/producer.rb10064400462 Bytes59238a3ceede2bcca673bd64eda6200aa3783785a8ec219f43cf3746e5301317
circle.yml10064400678 Bytese3c352a118e95655b2607879fa3e8ed7a64d28c3d46f514f593b814cde19d8c3
examples/consumer-group.rb10064400565 Bytes5296d1a97c4e906a66667887fe4db533d960c9aeca785c23eeeca0bfb8e48b20
examples/firehose-consumer.rb100644001.32 KB50b2116bbb92df58705f6f1858c8c1baa1321e39ae981c39482211bcbf31b714
examples/firehose-producer.rb100644001.16 KB946acc8aa21b964c363284147bbf92ac2a73f3457a92073a2b043145c0443ef3
examples/simple-consumer.rb10064400811 Bytesd222113d2ce4f1dd8c3a21e9821ad174922345c89871394108d63a2abac249fb
examples/simple-producer.rb10064400864 Bytes0286681f6a6ef1d7892f3852ff961f5baa7c510729e996678d1868589ef03f85
examples/ssl-producer.rb10064400985 Bytes34cfa028e66c812507e178b7bdb0c0ae9c00c277ec5444d41ba0bcbc448315e7
lib/kafka.rb100644005.14 KB3fd33f0f4896918e6a619f0bdf2471de38de8f1d9ad847f48619f6ff9429b350
lib/kafka/async_producer.rb100644008.12 KB402201ae5daa482f94f91d5d7b4db493c4ce66daba3b86f603009f477f11b64f
lib/kafka/broker.rb100644002.84 KBe787ea4a1a4ea3ec5c6957681cba4ddad2de8ed1d02965e3417ef74a6c1852af
lib/kafka/broker_pool.rb10064400834 Bytesfdc351d8b39427b0803b3cf40eba86f273b7e7ad1f12c3be38a951837b9bb172
lib/kafka/client.rb1006440019.2 KB6499087f4d32f22145834ef89401601f29115c1d4c98611d50418985c40bdf51
lib/kafka/cluster.rb100644006.78 KBe5f9e87bd99fe33facea8a235d7f9526d4d15c21dd1ff0fef45f40fa9cc0e92f
lib/kafka/compression.rb10064400511 Bytes369b220690094ec1eeb5dcf09a89810d4c1c55c52e22e8c7286f03040ccde4c9
lib/kafka/compressor.rb100644001.78 KBd8436a7865b30a493951496a2c3b6a9525f366bc343069d888ef45c52fd9ec65
lib/kafka/connection.rb100644007.09 KB13da8dd5c9c4108737257d7a6e1d45147199828cc7a1a6b4e1432b4840b7369f
lib/kafka/connection_builder.rb10064400837 Bytesae56ade62ece9e5e7d9081dce0268ef347cede6b96cc74838ee32a260e910e3b
lib/kafka/consumer.rb1006440016.1 KB21ae19abab712de23b8438203814867a3fdb65a69b384fb72c190081faa80fc2
lib/kafka/consumer_group.rb100644004.9 KB883647c5459b27f9345083274f8b46fb14dc6846417325799814548d126825e5
lib/kafka/datadog.rb100644009.12 KB85af3f556b1bb40eba3c2a67f6fb7a5abf4d70b41b89415f680b66f6b4f2e250
lib/kafka/fetch_operation.rb100644004.4 KB90dc8bc39dc6b8dbf1882e8a231ad7db3a5aeeae2bbb7b9addbbb9555ba39870
lib/kafka/fetched_batch.rb100644001 KB05cd1479516fc8af1e6bd9ad7abe8751f118a1abdcfb90fd3dd52f75951112f5
lib/kafka/fetched_message.rb10064400799 Bytes740b4ae14db1c7f3e81b6a4778bd44234febdc76e078cbab47edf5e8d76a0c2d
lib/kafka/gzip_codec.rb10064400518 Bytesb5ab2624e25615cd2a72c968f7a14dc70cc9db0aa5a7b9622d5b3c86746e5905
lib/kafka/heartbeat.rb10064400321 Bytes2ace01bf588382693bd9616b13699496169fe5481780f7883be9ea411d81842e
lib/kafka/instrumenter.rb10064400850 Bytesfc479fe25b9b699657c0ef64aafd4304c06fa948106e54a40072112e791c365a
lib/kafka/message_buffer.rb100644001.91 KB2e437a5b60b2437ae2c7cc3e7850a918f88f2a861afdc09f84e9bd73a2a07102
lib/kafka/offset_manager.rb100644007.81 KBb73369345ebb732ca705688d36f59c4dc0e94aa9ddf29b7c0c909c9294577f21
lib/kafka/partitioner.rb100644001.08 KB5c235bfc316a6e67576af91f05d8f83e7c810feabb9f8e0045fe93384f9832c7
lib/kafka/pending_message.rb10064400729 Bytes6d60ab93963216b40805946ac14af0f0f51635d9e3a484118a57d79872e03952
lib/kafka/pending_message_queue.rb10064400627 Bytes5d035894d99b60bca7a49ff0a611a348b34d2707668c8607612f17f3b7d33800
lib/kafka/produce_operation.rb100644006.26 KBdeb72eb9108cb0de754efea6a760cc2cd3ce184dce5f328a56f07fe2f842a739
lib/kafka/producer.rb1006440014.1 KB197ea4fa4db8ead39a6cd4d10c39d176f099d94508833b96ee48f358ca5fadf8
lib/kafka/protocol.rb100644004.26 KB8b952b7a35dde32319929be8d0f7f4524a53bf381c7d24542c856c12e27990e4
lib/kafka/protocol/consumer_group_protocol.rb10064400423 Bytesef2b1da289f175c36c372ae5ca3dd969821b33681e3ae2e031f758c50fa211b4
lib/kafka/protocol/decoder.rb100644002.35 KB114cb78c519286088589eda9954d214f0385922bee2c220f47043649f6754572
lib/kafka/protocol/encoder.rb100644002.49 KBd983fc93d169cee5444e23a8af92c36f7d2bad07568504118e223cf1aba55fa4
lib/kafka/protocol/fetch_request.rb100644001.51 KBb82986c7a33245f653a28650ee9ca4691af5075e01033de0f74b991576e0cbef
lib/kafka/protocol/fetch_response.rb100644002.05 KBe942301e0ebdfd5a3fd72141dd156bff08533af05027460e0d89b2f44513fc26
lib/kafka/protocol/group_coordinator_request.rb10064400359 Bytesa36ba1751ca42f473c4462c31962fdcefb77b54398fc5a5311483bd3907407ce
lib/kafka/protocol/group_coordinator_response.rb10064400681 Bytes6c0faf47b28f2389394433ae3172ba9687fe48318cd87e6044b18814e106e65c
lib/kafka/protocol/heartbeat_request.rb10064400520 Bytes1939772b36c7cc443b7208877d6c329c3d7d2837c53cbb89a69fce89a00245b5
lib/kafka/protocol/heartbeat_response.rb10064400266 Bytesd487bb6ed93c059cfee98612d8f0393bd502bd3217e277882c68a5b5d98c2810
lib/kafka/protocol/join_group_request.rb100644001.01 KB913fc604414999cb0446e5d69c6d884518619a2560c856aef1df5446889b571d
lib/kafka/protocol/join_group_response.rb10064400858 Bytes75f5a869558a598664e04858877a9311006299dd1069124ac7885b09d9daaa77
lib/kafka/protocol/leave_group_request.rb10064400425 Bytese15192e20e4d3c005f51152cc26b68d008283db43525b6a0111a4c84ba9116de
lib/kafka/protocol/leave_group_response.rb10064400267 Bytes8a9887ed4d42dfbcc1306ea73b060a06e23d3b39f2ba4ac2eb66752426186a4f
lib/kafka/protocol/list_offset_request.rb100644001.11 KBeaecd35fba189f561720011fd01ba02ef3dc88d616e891995b59d9258bd5eded
lib/kafka/protocol/list_offset_response.rb100644001.97 KBf122d94de9d3f75e91bc0f94aef41a4ee592a411c29f1aec547c709bfea2702d
lib/kafka/protocol/member_assignment.rb10064400946 Bytesc13f289381f59f125323cb9f56cc03ced042603804e3246208c869941f141c30
lib/kafka/protocol/message.rb100644003.29 KB034f6479d0358b833a4a99fa70e4cd1417c7784394eef6b9bdfd04ee8ada2b6d
lib/kafka/protocol/message_set.rb100644001.05 KB939cfd2870b7eb7670627bdcfc5909e256999bf4c6194fcf3350a8e28b718d74
lib/kafka/protocol/metadata_response.rb100644005.44 KB634e6b9fe0734e78e776c6ae5113e6b3ac44ead62ddb986ea4d64410a4430093
lib/kafka/protocol/offset_commit_request.rb100644001.16 KB555dd324e69d980d12bd96d4f8daba36ac98687683262e7eaa6df7c55b8fced7
lib/kafka/protocol/offset_commit_response.rb10064400527 Bytes21ea1be5cf683c1b73c9d8d121ac9dcfa5d1524028e8edecc672fd03c577451e
lib/kafka/protocol/offset_fetch_request.rb10064400647 Bytes0f0a7deecf3590fe8513021a9de6ab1f1a471e6fe47596ab67c89b6296100c5d
lib/kafka/protocol/offset_fetch_response.rb100644001.15 KBbb585e73abca33645495ade81958fabdef6162b71f1ca84ce9191fe6a8b736d9
lib/kafka/protocol/produce_request.rb100644002.34 KB7891c092e1231834d675c153a0b6d7a56a5440c42f66b76dcb010019c41ff83b
lib/kafka/protocol/produce_response.rb100644001.49 KBcd6fdce807563916b0996b7cb78f82086e5a93ee097612880f7d269df1a835d5
lib/kafka/protocol/request_message.rb10064400601 Bytes5c882647f314c7a8bde4a7cfbc15d10fe7e87e2d6eb615b562b384790c0d7d33
lib/kafka/protocol/sasl_handshake_request.rb10064400674 Bytes9e7155d12003f380d75f8a557c5b07c487e71315f2d9b07339a6962d8df4bb66
lib/kafka/protocol/sasl_handshake_response.rb10064400615 Bytes55f9e1ccfa589219bff1d18c419cf3472050af24e4d9ed2fa7a56323a5da3328
lib/kafka/protocol/sync_group_request.rb10064400794 Bytes3ab74d5c51f854f5f7bc7977243b021d2183b611b1c61e348b145d9c417880ca
lib/kafka/protocol/sync_group_response.rb10064400508 Bytes8b6d9f06cfd5cd933b1a8ff9392f3f5af88fefc1684fb5a56cd4d1757adc2cf2
lib/kafka/protocol/topic_metadata_request.rb10064400475 Bytes56503c9f2b7688a08df590885e6681d254dee3a8259c8f11f736f7370d13dab7
lib/kafka/round_robin_assignment_strategy.rb100644001.25 KB0c42eb8505e9b6ed8dec14b08d667170859b0d29185a94ca4fc9f85b51e0ba79
lib/kafka/sasl_authenticator.rb100644001.59 KB672e214f0d6a4cae3d33aff234f53643c5939686d49b1b7b2db0d9a745915dae
lib/kafka/sasl_gssapi_authenticator.rb100644002.22 KB1552c17b37e49faa62cb64a5f57ef14c81319a585fb2cee4b227ddab4fb014da
lib/kafka/sasl_plain_authenticator.rb100644001.13 KB24b70dccc9d10f9025b2b7623ddbe7d2380631b300e7accc561616ba304a6236
lib/kafka/snappy_codec.rb10064400437 Bytesed496f54fbe5bf46be197a5077e0c01891ed00e766932b9f08f85815ae79137f
lib/kafka/socket_with_timeout.rb100644002.83 KBd9e43689b8c42ccb6693a048a2e0b357f071ce1f63a3fd62c49e90ccb887eaf7
lib/kafka/ssl_socket_with_timeout.rb100644006.17 KB75acdae005194bf7649b5c4a39eee71bbbb2acbe2232f04e80aee767fe7a6084
lib/kafka/statsd.rb100644008.37 KBa120cdae3f1f0c9027bff87407d051133e1f0f2a27ed1f7a200ca86a01d6618f
lib/kafka/version.rb1006440043 Bytes24dd6e9e381c481b4bf48da92e9cbbfaec4cf85f69d950e9d80727467d1218e5
lib/ruby-kafka.rb1006440073 Bytes824f3c16fb05879c1c499308503433e3d2758fcb86db251432eddb9ea4e29fb6
performance/profile.rb10064400684 Bytesb7e5b02d2a51cb7a939fea276338fbc94af6567204599e330c01f42619f466a2
ruby-kafka.gemspec100644001.76 KB1ed341f20f8e4ff89ddbe4d82cc0f18878627369801ae9b3ff42e1fe02ee43d2
vendor/bundle/bin/bundler10075500409 Bytes66d3aeb8bedde8a035007fa708df5f2c6ddf1e0c68fedb157ed113ab7aa06a28
vendor/bundle/bin/coderay10075500409 Bytes1b6dd99554797eb83730c17eeabd0cdace8c2cc651e69bca2af0ef35b1ee5e5a
vendor/bundle/bin/dotenv10075500406 Bytesbee371c80b5e7ae490ed65f488cad80dc2c4337c625e1d2dde8a1d901677d0d7
vendor/bundle/bin/htmldiff10075500412 Bytes587edef13af5912622d9c82700d7f0b61a327a27304a17b559a2a854f70258f2
vendor/bundle/bin/ldiff10075500406 Bytesd1df40ff9d3fd58549692d17a8fac36fb5086539d4f222e10abc94b6b3f449b4
vendor/bundle/bin/pry10075500397 Bytes80c24706e0af04a09bf6ffe573fac32c75ca92abada7189e920eaba25e7018b4
vendor/bundle/bin/rake10075500400 Bytescdfd0970175505a342cc0a7f0b95e3736c67ac8c52dfa5481a7aed2c157f9cf2
vendor/bundle/bin/rspec10075500408 Bytes7437b2f54cb914bd3d433ada8d7a53ff1726cd17fd31ae64b946810e35397873
vendor/bundle/bin/rubocop10075500409 Bytes4e798a6cbf83aa9406df252bcc540b2a9e37a20e0fd2b426a6764a97c4341095
vendor/bundle/bin/ruby-parse10075500414 Bytes87f40ec7d20863081cda5e2b83b7c4dc8b36f694564b22a6f604012abc2bd948
vendor/bundle/bin/ruby-prof10075500415 Bytesc993b4674b748f46efc50e77c1f694e54eed86095e75fa5f8292dcdfc027ca1c
vendor/bundle/bin/ruby-prof-check-trace10075500439 Bytese7dd82082c7ec1e2928075263ae761a71c70760e886ea42d095626d16345ac90
vendor/bundle/bin/ruby-rewrite10075500418 Bytes37dcb4570f0a3a5692be3335b710de007027f95f7033147d73e42a0770637990