ruby-kafka-0.3.2

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899444

number: 0.3.2

platform: ruby

spec_sha256: a951b5895518c0f0539189170cb315fe33265299bba24ee2b63d17789599cbbf

sha256: 1769a85d3953d8e725a0f1bc603424fb655bb776f8b5a3437baed819bdc819b3

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

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

position: 94

version_data_entries_count: 76

uploaded_at: 2016-03-15 10:23:00 UTC

indexed: true

has_extensions:

extensions:

Gem size: 48.5 KB

Version Data Entries

Total: 76

Unpacked size: 170 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.gitignore1006440092 Bytes47b9710cb343396e1c3daa8fd99f530f37e0d5ac5c4cacfacb2632cc3e43c981
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md10064400633 Bytesd4fb59a218d8eab469f2a9dd86c84b40c9367b6f83ed9e213b9c7f4af9be3246
Gemfile1006440052 Bytes42796cc19af6cf22b7bbeef298a74d1f66d358bd73f7eb194df56c652f2dd846
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
README.md1006440026.7 KB9dc91eacd500265b75142674a879ad3b28de29c702d96cc1798fc1f6f7cc2077
Rakefile10064400114 Bytesd0726d260349476762de87bdd5c451c7bfe6e0e47fe09df9f011e120f1fd316b
bin/console1007550086 Bytes6e7cdf8cdc22cf29f16f4261589138eb0cd4e9f88a018adf9767c797fba13b38
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
circle.yml1006440047 Bytesf052d001c6f7985c07504c5bd2d2357c110a7ea2d75d704d78b2ea3e14efa9fb
examples/firehose-consumer.rb100644001.32 KB4e96625825ac90a665e4fd92a894d225cbf06ee0aeb502a9d831347e424349c1
examples/firehose-producer.rb100644001.2 KBbefda24bf9183217ce6c0ae4e3d3106667027ef7e63534d63a7725210c971966
examples/simple-consumer.rb100644001.02 KB8525a99dcb507aa29f28602cc74967ba0f740d5d0e205b6046ed101a790ecf39
examples/simple-producer.rb10064400875 Bytes031f0602b0fea22476c8ece62c63f0db6e2c83213bb134167ecd57f11b3b463e
examples/ssl-producer.rb10064400996 Bytes79c1022861219559e1616ff38d0adc9e079a6f72b00fc5246d0b2abbbe91333d
lib/kafka.rb100644003.53 KB1dae7d04da8fe4a2b9b9ea02163730f782e76bdbad601aff838272e1d9b6d920
lib/kafka/async_producer.rb100644006.22 KBe658e89fb625b6ac723ace78a7aac36ea5f1b1f15d79765608960df7dc9a255d
lib/kafka/broker.rb100644002.8 KBbd55d4e38b7f674ed0ee528b60bafb0a45f135e7a8aebe2f7b4fc9369f178b07
lib/kafka/broker_pool.rb10064400968 Bytes950f6983462a94e53a919f524a130fa9e63b94f300f4da3cea25b4fb79f6287f
lib/kafka/client.rb1006440010.5 KB94c69a2df39e0ba8cdd573df52740cc3436d5a50048cca6ecf0df4e93926fb35
lib/kafka/cluster.rb100644004.61 KB12423d0db8f8036e0f099aab750be5a7a5be720ece20a3ff8f19935163d98c2e
lib/kafka/compression.rb10064400511 Bytes369b220690094ec1eeb5dcf09a89810d4c1c55c52e22e8c7286f03040ccde4c9
lib/kafka/compressor.rb100644001.74 KB75cce7977c52eba8a2726b335ce620cba113f5640a4cb227d7b14570f76f9082
lib/kafka/connection.rb100644006.45 KBa860079085089e824e9d4abff399ee81b60981746127d52b56e61d8041fadf1e
lib/kafka/consumer.rb100644007.83 KB9917f12034e47a5d56718a2bbdf3c65822ef502c80fe6c8907d7b27b99f68344
lib/kafka/consumer_group.rb100644003.87 KBb7d602fd7a603f60d4ac3f5ece5f8b57a4f8a46f34b25843cd915e4314a5c944
lib/kafka/fetch_operation.rb100644003.78 KB6b4cdbca356387e4106c129b3a99d35b213f74c74f3d7d855d4084b04b86e5ba
lib/kafka/fetched_batch.rb10064400374 Bytes33a6809a1a79c41cf4ed4db137fb01a591270c642d9f16b9552a57046c99acc7
lib/kafka/fetched_message.rb10064400671 Bytesd45ba1cdf452f7a35ad1017cffad9a29276ce0cf1999ea9f6648be45b6c32a11
lib/kafka/gzip_codec.rb10064400518 Bytesb5ab2624e25615cd2a72c968f7a14dc70cc9db0aa5a7b9622d5b3c86746e5905
lib/kafka/instrumentation.rb10064400290 Bytesfe25fbfb397d1c4c9650010262a1a328854ce6424c64c934fe0dd1a3a9b733b8
lib/kafka/message_buffer.rb100644001.81 KB32326ca193f69621c01f2e2ee2ac09dfe82c206c935b8f4764f836e82febb104
lib/kafka/offset_manager.rb100644001.87 KB2a98ebfa5a442abdc0f58f59a08b9245c78071a8514fed6a47fbda9933ac01a6
lib/kafka/partitioner.rb100644001.08 KB5c235bfc316a6e67576af91f05d8f83e7c810feabb9f8e0045fe93384f9832c7
lib/kafka/pending_message.rb10064400461 Bytes49d9eefaf5af4ea99a0b5c74512f3c9b0648b4958645d83c2166b149c1819b59
lib/kafka/pending_message_queue.rb10064400997 Bytes9cd516c58a6a71e484be0ca800a7cb49a3771b54ce19b78bdc172888c069ab67
lib/kafka/produce_operation.rb100644005.57 KB73b38a65e63fca8d7270b91e4480337f7ca5e6f809e8a208c8bc2c424cd71b04
lib/kafka/producer.rb1006440011.9 KB463d6d01fd1e4aa1244580ad4f21466cd7f0c3d8c770a5a20f089863553a350b
lib/kafka/protocol.rb100644002.43 KB1c986366299463f280ea954d455643f706184eb4da0f9dff1b08bed917baeab9
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.rb100644001023 Bytes602fb19c9025bd4286250bdbad024e35580788e1cadacfca315d8423ce1fa647
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/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.13 KB42e88af026456c8c4805a98b23064146209af0d3a6a9b85cbd77ff883ec6c0ce
lib/kafka/snappy_codec.rb10064400292 Bytesf58ece1a2d34df08cc39c20491e79c94b0ed54c0d8d27e953636cf3e6e76977f
lib/kafka/socket_with_timeout.rb100644002.74 KB1f042184092505f61a929d1f5f2a19e5d6f5cf9a305e7aebba37e1cbd8a3ca18
lib/kafka/ssl_socket_with_timeout.rb100644005.47 KBab5e8342715293adf8ac463226a0d652625054158e3e7f308429ab3d5e3e9e13
lib/kafka/version.rb1006440037 Bytes24bc6b7aaccd9727fc4e593d16d61cb4f6cc60735fbddade11a7c6dd38e9a991
lib/ruby-kafka.rb1006440073 Bytes824f3c16fb05879c1c499308503433e3d2758fcb86db251432eddb9ea4e29fb6
ruby-kafka.gemspec100644001.42 KBf9a22252fd6daa33acaa0a8bbe1f66eaff65a3534d3c301e05017b048f3903df