ruby-kafka-0.4.0.beta1

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899453

number: 0.4.0.beta1

platform: ruby

spec_sha256: 32ab2265fee99f9e56e0961f43c4090c52c16f1f83c084c5f66b52f6feb6921b

sha256: b3afce68d262948f8f768901acbb01c740b41eb51c116072698c89fe216a1e7d

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

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

position: 68

version_data_entries_count: 101

uploaded_at: 2017-07-18 10:50:12 UTC

indexed: true

has_extensions:

extensions:

Gem size: 69.5 KB

Version Data Entries

Total: 101

Unpacked size: 254 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.gitignore1006440090 Bytes1f0f18648a763fc315edc7e2d4c32ea009593e8acc9714c3e935011a490b6617
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644002.95 KB7b47460f36b625ac28b06b4f3e8681300b387158cb807f93cd99db772331ea0c
Gemfile1006440052 Bytes42796cc19af6cf22b7bbeef298a74d1f66d358bd73f7eb194df56c652f2dd846
Gemfile.lock100644001.78 KB8e2314cb813b50cfc11957e345bf117d743f4766d4a4813524b5297c6abd9fa6
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440050.6 KBd17ac46046cff740b873e413df7f6ac74ccfb79c1edf2f4522de098779c40d57
Rakefile10064400114 Bytesd0726d260349476762de87bdd5c451c7bfe6e0e47fe09df9f011e120f1fd316b
bin/console1007550086 Bytes6e7cdf8cdc22cf29f16f4261589138eb0cd4e9f88a018adf9767c797fba13b38
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
ci/consumer.rb10064400347 Bytesbaf3e625ff8879df692c616e1d6531adf78364ac85e3cf5f40c0c486dbdd3806
ci/init.rb10064400466 Bytesae9d8e2431228b07e30e14c4da0583edfd78c8b15eae0146ad3346976bd51741
ci/producer.rb10064400462 Bytes59238a3ceede2bcca673bd64eda6200aa3783785a8ec219f43cf3746e5301317
circle.yml10064400659 Bytes177c14d7734a2ab194aaf1c2362a359feab2040c5ba4fe78348363a932be360e
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.rb100644004.84 KBf86f96f83897d6f9ea8886601f15ea604cdd5939fe0f0da53de4da67c15ea4b5
lib/kafka/async_producer.rb100644007.34 KB538fca08a952906ccf7437b8be1db379efcb6ff548df0c4d48f46ddac879f3bb
lib/kafka/broker.rb100644002.75 KB32d61662797571b7ef02ead65adc171118b534316aeb33e8996248ac781be3be
lib/kafka/broker_pool.rb10064400697 Bytes931488be982aac4aa88d895e9b0b8ab3e12faa6b9a5ac57d6c989b1e549d3cbc
lib/kafka/client.rb1006440018.9 KB1fb2bddcb185ae2e6ed986d60f0ede7d5292d0ab63692df687408d8c537c019f
lib/kafka/cluster.rb100644006.15 KBa1f1e8272187174bde7704cbb9c53d00b3dc76c900f15029b142abbb6c4e4313
lib/kafka/compression.rb10064400511 Bytes369b220690094ec1eeb5dcf09a89810d4c1c55c52e22e8c7286f03040ccde4c9
lib/kafka/compressor.rb100644001.78 KBd8436a7865b30a493951496a2c3b6a9525f366bc343069d888ef45c52fd9ec65
lib/kafka/connection.rb100644006.57 KB1d600f3093bc294bee860698fe82a65a71f7ca48e19e900a5fb2b1a94f6273ca
lib/kafka/connection_builder.rb100644002.15 KB47dc05744aad6f391c5e80e747d5f409b86b0e84fbf0c4b454c296b74af63375
lib/kafka/consumer.rb1006440014.9 KB38511a7c0881982be0a7ed73a670fef1f33de657a3f255ab0589fce06c96fbe2
lib/kafka/consumer_group.rb100644004.53 KB4b4f4534ab6d476135202f84e13064ede6a6bca48d879d78eb6870144fb60b13
lib/kafka/datadog.rb100644007.17 KB6d27c5c56202e3caea1fc8f982e79b320684562f771b4339cc0a79f3e3700129
lib/kafka/fetch_operation.rb100644004.24 KB4a9c476e78876683043b84b8303dad188487bb0ef8a2ebd342fdf97265074239
lib/kafka/fetched_batch.rb100644001 KB05cd1479516fc8af1e6bd9ad7abe8751f118a1abdcfb90fd3dd52f75951112f5
lib/kafka/fetched_message.rb10064400671 Bytesd45ba1cdf452f7a35ad1017cffad9a29276ce0cf1999ea9f6648be45b6c32a11
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.rb100644004.9 KBcd7b504f86a20b50ba1c4ef2b43310a0eaee6a8e05a09a4e5d39bbacda6d3f1e
lib/kafka/partitioner.rb100644001.08 KB5c235bfc316a6e67576af91f05d8f83e7c810feabb9f8e0045fe93384f9832c7
lib/kafka/pending_message.rb10064400173 Bytes7d1762e4a3d0fc83f5bc45811d3e432fd17f5549f10e897aef3a9383dc61e244
lib/kafka/pending_message_queue.rb10064400627 Bytes5d035894d99b60bca7a49ff0a611a348b34d2707668c8607612f17f3b7d33800
lib/kafka/produce_operation.rb100644006.18 KBbf871348cb0e63da81003a16c9965b07e5ac0e9f5a49f21bb6327c58fc437ac3
lib/kafka/producer.rb1006440013.1 KBb92ec57c1b380f3df44213ab4448dd293a8e6ff76b6cc2788979ee70e88d6468
lib/kafka/protocol.rb100644003.05 KB09559bbe0fbe6ebec5fb4eae29852d522b7cd9fd4b7364d70520fd5be5629323
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.46 KB9da02fa8536df9323b281559bdf5ceb4ee45876c8bdf47613f721a81d22a7683
lib/kafka/protocol/fetch_response.rb100644001.91 KBd6c793199f9a66b6a2fa492f558465fcd5a6ac4ffffcec02ee9246814b28a16e
lib/kafka/protocol/group_coordinator_request.rb10064400340 Bytese7306b4dfa7e494186736db7e9bd3c813efc87c51a5552d99b61489e2dd1c1b6
lib/kafka/protocol/group_coordinator_response.rb10064400681 Bytes6c0faf47b28f2389394433ae3172ba9687fe48318cd87e6044b18814e106e65c
lib/kafka/protocol/heartbeat_request.rb10064400509 Bytes4c678f9c809db9bc2d9f7a8bef2a793048acaafb4cab79e70a0c8a5fbba0abe9
lib/kafka/protocol/heartbeat_response.rb10064400266 Bytesd487bb6ed93c059cfee98612d8f0393bd502bd3217e277882c68a5b5d98c2810
lib/kafka/protocol/join_group_request.rb100644001022 Bytes75a81d73c1f7f4f5fe7c2bc93b2ac0db1985a9cc9ade5528ee6a325859c649a3
lib/kafka/protocol/join_group_response.rb10064400858 Bytes75f5a869558a598664e04858877a9311006299dd1069124ac7885b09d9daaa77
lib/kafka/protocol/leave_group_request.rb10064400412 Bytesac836aef5afb1e5b53884e1f49e8fc44746a16308b2c47fe57c78d3a6b84bd2e
lib/kafka/protocol/leave_group_response.rb10064400267 Bytes8a9887ed4d42dfbcc1306ea73b060a06e23d3b39f2ba4ac2eb66752426186a4f
lib/kafka/protocol/list_offset_request.rb100644001.1 KBaa27cf66d3dd31f59ff39ac5437efeb8d33bd742f26606de444ead90095783da
lib/kafka/protocol/list_offset_response.rb100644001.97 KBf122d94de9d3f75e91bc0f94aef41a4ee592a411c29f1aec547c709bfea2702d
lib/kafka/protocol/member_assignment.rb10064400946 Bytesc13f289381f59f125323cb9f56cc03ced042603804e3246208c869941f141c30
lib/kafka/protocol/message.rb100644002.62 KB0e96f1642c4f14df2b2aa2331bcd8e1c99b7fe481236a8b87272d6466e2c5e63
lib/kafka/protocol/message_set.rb100644001.05 KB939cfd2870b7eb7670627bdcfc5909e256999bf4c6194fcf3350a8e28b718d74
lib/kafka/protocol/metadata_response.rb100644005.43 KB6f520aef2bf6763a76906f90b4aa07c35534bcef415ce558276a138c317613f4
lib/kafka/protocol/offset_commit_request.rb100644001.14 KB3bf66d974a17c5a78fd58bf96248730b899c7befeb428e1a4c962343f9a775e0
lib/kafka/protocol/offset_commit_response.rb10064400527 Bytes21ea1be5cf683c1b73c9d8d121ac9dcfa5d1524028e8edecc672fd03c577451e
lib/kafka/protocol/offset_fetch_request.rb10064400632 Bytesf69bb2ad4ee4662f10bd65c4a97065d02f12785d6b5f0644e040450e4490e5b4
lib/kafka/protocol/offset_fetch_response.rb100644001.15 KBbb585e73abca33645495ade81958fabdef6162b71f1ca84ce9191fe6a8b736d9
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/sasl_handshake_request.rb10064400658 Bytes28741774f6985a93cb1452ea8e828949a09472c27a0ad14629ce30c7abf44832
lib/kafka/protocol/sasl_handshake_response.rb10064400615 Bytes55f9e1ccfa589219bff1d18c419cf3472050af24e4d9ed2fa7a56323a5da3328
lib/kafka/protocol/sync_group_request.rb10064400782 Bytesa36acdc0bbb9c17be312c0286068e82d4ac09ccf85aff744a93ff871f47a93c9
lib/kafka/protocol/sync_group_response.rb10064400508 Bytes8b6d9f06cfd5cd933b1a8ff9392f3f5af88fefc1684fb5a56cd4d1757adc2cf2
lib/kafka/protocol/topic_metadata_request.rb10064400458 Bytesa86e03eba101531b12c2e25dfa213902399389c2eb51d268418b811a5037483f
lib/kafka/round_robin_assignment_strategy.rb100644001.25 KB0c42eb8505e9b6ed8dec14b08d667170859b0d29185a94ca4fc9f85b51e0ba79
lib/kafka/sasl_gssapi_authenticator.rb100644002.01 KB05093ee708b9eda8de7ca702c3365cb7c3106c61a523295171103edde1337683
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 KB91351d32a6065540c972b6a858faa7c070e9b13921e6daaedc5ac7f7161f6558
lib/kafka/statsd.rb100644006.88 KB464920165146114d339f513d459e3ce4ef083bc121ab949fb98e025a17b8993d
lib/kafka/version.rb1006440043 Bytes78c30299fd6f705c6fee2279c8d078866266b6f0b1589862cedd8c1ea83a89f9
lib/ruby-kafka.rb1006440073 Bytes824f3c16fb05879c1c499308503433e3d2758fcb86db251432eddb9ea4e29fb6
performance/profile.rb10064400684 Bytesb7e5b02d2a51cb7a939fea276338fbc94af6567204599e330c01f42619f466a2
ruby-kafka.gemspec100644001.7 KB19cadbf312b503a36fe2cf443124e5bf42439537bb148be7b8d5786a1206d7c0
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/ruby-prof10075500415 Bytesc993b4674b748f46efc50e77c1f694e54eed86095e75fa5f8292dcdfc027ca1c
vendor/bundle/bin/ruby-prof-check-trace10075500439 Bytese7dd82082c7ec1e2928075263ae761a71c70760e886ea42d095626d16345ac90