ruby-kafka-0.6.1

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899481

number: 0.6.1

platform: ruby

spec_sha256: 0d2c53a607866cc29c6b62933fcb562792dc8de37e6b11a57b940b3c0432aa44

sha256: afb9623900eb534fe1487680817ab2d23e07121fa403d3992e0d7d183004bf4e

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

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

position: 39

version_data_entries_count: 110

uploaded_at: 2018-05-04 11:58:08 UTC

indexed: true

has_extensions:

extensions:

Gem size: 86 KB

Version Data Entries

Total: 110

Unpacked size: 327 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
lib/kafka/cluster.rb1006440011.1 KB3dcf257aca1e96f41d9dcdbf3887e32de5313e0154c1703858fe66ad3279418f
.circleci/config.yml100644003.53 KBae576efab08afa7c61f743efeb552d8bbc4c046f3aa628241060661e0ba78349
.gitignore10064400104 Bytesd7d42fff0538e1c089ce94148a5c59a50d4557246d72209feb58d5e58b8a26da
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644005.18 KB84c4c4d75d287ee72f55fce23e7766b56a2f74174c28a8daf2c006a6cef0fd1f
Gemfile1006440070 Bytesbbf84bea967ac012444426fb7d35999ebb3e2fc9ceb7d76ba129e6466f1d8d2b
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440060 KBa5a473346285b289c9ac613ed3180e2285418d5923ef588ef17f9afaaed72054
Rakefile10064400145 Bytes572c94da7052083b39b62a6600785419e314a109efd7a3d8c3a96eb77ad34fd1
benchmarks/message_encoding.rb10064400432 Bytes0bcd32703ae8c1f1f4363d3fee3bb9314cd3407834c5c3f3055298e45f405153
bin/console10075500116 Bytes4e711a103a47e456d71dba0c6bc0b1e79354557db248589ea5a60cc6c56eb251
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
docker-compose.yml100644001.02 KB36c6d99c1cbfc0a3a60c2fd1f3919a603c95a36eeec4b39f7337e670bd1e7241
examples/consumer-group.rb10064400739 Bytes11287ac791ed6e8e9c1eb01ed230d46e030d67c2544f94753913ff199752cbda
examples/firehose-consumer.rb100644001.35 KBc0cea723d7f9f40ffaa967bac762b6a13765059b7565adb22cb030261fc0dbed
examples/firehose-producer.rb100644001.19 KB52ea40610210fa972280f8e4a28ef0a88464cce0bdaacf43bc9ed8ee6214765b
examples/simple-consumer.rb10064400853 Bytesada6005ea54048e3fcbe4e467caf8bbbfe93e514e03fc4b471e60789b90febc8
examples/simple-producer.rb10064400895 Bytesfd6e89ea15ce9b5a9986cd2112ee563340445001826428825e727465ea7a07ba
examples/ssl-producer.rb100644001016 Bytes133ef25eee602b586e81039f76ded45e43bc0828a0daab4c5ef4af8ef216abfb
lib/kafka.rb100644005.73 KB467f218924cc72adbdda46f5132139163f9417ff5452bb1bc18f75d2e94f2324
lib/kafka/async_producer.rb100644008.18 KB08986199843c511bf5cdb8a6b3a30d8891d484f17cd55dfbaf22afcfc0989a76
lib/kafka/broker.rb100644003.99 KB05d882d86344e6269be48f2b44ac420aeedb67c107ec5ccf84c6eb1c916c25d4
lib/kafka/broker_pool.rb10064400884 Bytes66f56902ae80d587c564f69c397030bbcc71d8c7996f870c0cebe4c20ff45eef
lib/kafka/broker_uri.rb100644001.01 KBcb53169ff8a20dbe5f2af0d54ecb5727d27f914f9d4c57f85b8d97ab8153e402
lib/kafka/client.rb1006440023.2 KB0288aa14f3f84ec119a6abe4654c33882a7c8aab1cdf579ce882718df26d3dac
lib/kafka/compression.rb10064400764 Bytesfb4e38bfe28aea8c58a36b1cbbfeeb10c43bc230eea8568b04c10176b02202de
lib/kafka/compressor.rb100644001.99 KB5c325cf1356986c260a2f89d1fa27cd20f0733e376bf4d8cdcc34348ec6bcd18
lib/kafka/connection.rb100644006.91 KBdaeb84702fb7b2a891ab3c9ba0d52b433b71600538ddb9abf98e077d2673237d
lib/kafka/connection_builder.rb10064400873 Bytesc61bdf2d70373387f0c5384840b4e96abff6848490c1710b6cf91e7d15f2b4a5
lib/kafka/consumer.rb1006440019.6 KBbcb1b9d6cdf9b20e714b5f61cc3261d6e08a9693c885ddc6864aef5c5e00974c
lib/kafka/consumer_group.rb100644005.06 KB2a72a0a3131be91b045bbd57dc4d86a133b723f6dde87e8dc0279e6c8ff67a59
lib/kafka/datadog.rb1006440010.8 KB24fd78f0650a751ed73f95a3eda1e4a706807e71919c2d0fd22aa4ebd74cae16
lib/kafka/fetch_operation.rb100644004.47 KBeccbef93ca1f9e69a8810bb4e325623c6d1326d9c6df9a037fab76a8bc64cba4
lib/kafka/fetched_batch.rb100644001.03 KB9e98b0a6c6ae1b14fdc8d25d49dfb9bef388e4d7b0429e8c2c30a11006d3867c
lib/kafka/fetched_message.rb10064400818 Bytes6b388ecfe71176964d3167b4c60f49a125eef19ec190636cb9428644e16957de
lib/kafka/fetcher.rb100644004.47 KBbf53560d3c2a80a4f0cfcd200cadc36ce032cf11553157fac5f1e1c4a5b69d22
lib/kafka/gzip_codec.rb10064400543 Bytesbef14b52c5127465add5fb9c3472a9d5fd32f91cb6064f6c3855592425b6e4df
lib/kafka/heartbeat.rb10064400352 Bytes6c918aa729e0212cd8b0bc91a5e068c075b185f7d4e2456273d7945a0d661901
lib/kafka/instrumenter.rb10064400881 Bytese67d7c8f911ee529d0160993a406554a088ed0141e837598558bb1d38b86edf2
lib/kafka/lz4_codec.rb10064400395 Bytes9287f64e8e3ba6dcab1868ad7cebba284731200e907e9062653ac0075caf9cdf
lib/kafka/message_buffer.rb100644001.94 KB2e4388d6ddd7786078984cc9fca9cdfb981d5bb02000e1342dcc4cf082d3c4e4
lib/kafka/offset_manager.rb100644007.97 KBe2b98ff6c7af608bca3027915018fa80f0bf5e19dff75c9f5e868e0fb5a2c54c
lib/kafka/partitioner.rb100644001.11 KBfbaed72feaafae2cfbbcc651be0cbad30ad90e76831a740b847f78b7c3bc5193
lib/kafka/pause.rb100644002.66 KBffa250fbc7c6fd9085f2709cf269774409a8edb591d9de9ea73082bb8a07ce02
lib/kafka/pending_message.rb10064400760 Bytesc0a884d076834eade53b329d0bbe5d395109806f746cbfd2d4f4eff2d8f8f921
lib/kafka/pending_message_queue.rb10064400658 Bytes1665aa4ae63fabdddc881088c8557bd39cdf33cee35fd97b534024b26bdb2b65
lib/kafka/produce_operation.rb100644006.29 KB8bf9be38a84ebfac7e5d5d5808afad8ab6e7bc66338dca9ca4661f42476f36ff
lib/kafka/producer.rb1006440014.2 KBa088389564378e1a166a26029fab2df68f606deb9ca9a89c70c4e5610837a7e3
lib/kafka/protocol.rb100644006.02 KBbcecb1a488a3d6ba3efbf6db6ed7ca48ea9d6e6080070a9a2ae91c0b2e0800d1
lib/kafka/protocol/alter_configs_request.rb100644001021 Bytes3ba71bfd5522d951709b875d7f48e212ed1286f73d497000b5a5203cc645f3b2
lib/kafka/protocol/alter_configs_response.rb100644001.29 KBf43de1e3384b7e03a96b71b673468cd894b0b69d60d7ba6d50e4e32828481808
lib/kafka/protocol/api_versions_request.rb10064400300 Bytese5d4cb029f8c8875540315fbcb49480475a7134ac7e201fd2c9d169f851ace9f
lib/kafka/protocol/api_versions_response.rb100644001.13 KB6317a03a04fdb99ea85d7aec785f42de401b82716c1c38f610d3264eae406d32
lib/kafka/protocol/consumer_group_protocol.rb10064400454 Bytesce9e5ae4977b88ff6b9669625483f50edc1757b5d1fb884e890d6aa3bf66726e
lib/kafka/protocol/create_partitions_request.rb10064400990 Bytesedf7cdf1c386a0fe7fd238f6dba53ed15fb812d529ee0e41b9651c0047f0c226
lib/kafka/protocol/create_partitions_response.rb10064400623 Bytes724255a265036fbb735babedb062d2e06dda615b0205ab303e0a25af90db1178
lib/kafka/protocol/create_topics_request.rb100644001.04 KBde56d3fd0cc3384832009899227c54657bfea4a252bf650105ba8fec4562e375
lib/kafka/protocol/create_topics_response.rb10064400423 Bytes9baaf17d3e9595f2d3740a51334fc8b8dced3a5e3a5d5dc17346edad2de3964b
lib/kafka/protocol/decoder.rb100644002.56 KB98ebe0725ccc033a22a529fe1cd9b3313c9fa40fb363d2bfc0717e13b4be63c0
lib/kafka/protocol/delete_topics_request.rb10064400587 Bytes089b5661d789e3189b22c4608db583a462978adb44b533b6cf65fa1b1b29e130
lib/kafka/protocol/delete_topics_response.rb10064400423 Bytesffeca4718965f9ad8067bac52fe2b318f606a7d5eed9c8ca9cf4ab96b5572d98
lib/kafka/protocol/describe_configs_request.rb10064400660 Bytesbc7de70788e8fe0aa94f62edd2b957a846705c69f3c389e143075e21d24a1a0f
lib/kafka/protocol/describe_configs_response.rb100644002.01 KB3d667874f19ed6fd4233b726766e99519536e55486a818d180e2d46a25671735
lib/kafka/protocol/encoder.rb100644002.86 KB85f3bef5c65152ff6f614b9b44b272dc5df53e353f5b4a1869feed2dcfad8339
lib/kafka/protocol/fetch_request.rb100644001.62 KB45753747fba7296469f398fe1a1bd16024cf1f7a975e2e9c1e3aa5f339977de0
lib/kafka/protocol/fetch_response.rb100644002.08 KBf4b5134feab1b607986dbfd5d06e45694f77e29297c14d0c1b9996f05671ab76
lib/kafka/protocol/group_coordinator_request.rb10064400390 Bytese1aa883e9fd49309dcce63db7014213dd4bad48a173863d299bfe3aef13187ad
lib/kafka/protocol/group_coordinator_response.rb10064400712 Bytesbce1603123b5be29385c2d946ebc41c0941096a4f61469ec647471ebf8887f0a
lib/kafka/protocol/heartbeat_request.rb10064400551 Bytes624e3edcca15102e4a2a600cfb60f0affbc904168aa92411b488e4fbf520bb08
lib/kafka/protocol/heartbeat_response.rb10064400297 Bytes465c33fb4ff768b8ded8014128637cf4193dbff313c7060cb305519b6e35ec30
lib/kafka/protocol/join_group_request.rb100644001.04 KBc785341fbb2d488de09fc2804a6094b024e1e46d626766e07b27d30e123005e6
lib/kafka/protocol/join_group_response.rb10064400889 Bytesc26aa6b133340ed47acda6f40ad2d09d1308eb5a70f82b05c893ab58002bed23
lib/kafka/protocol/leave_group_request.rb10064400456 Bytes92674b7c6a0fdc0ea22550aaf9da6531f013a3087773783e07bf2352beb4b22f
lib/kafka/protocol/leave_group_response.rb10064400298 Bytes735c9bf1e00e1259962104ab439557b5542e2ff7d2ebbaf848a9e03ef26776e2
lib/kafka/protocol/list_offset_request.rb100644001.14 KBcf282dd25419ddce734a2e30296d288ab7318d0984768cc791611149748eaeec
lib/kafka/protocol/list_offset_response.rb100644002 KB4e6b96c588cca21bb91dd203c64de90d632443eeea0142d884edf77980851e28
lib/kafka/protocol/member_assignment.rb10064400977 Bytesb14d0381c94c08eb096b45d01304300ba00a73cfb4ef7fe079dfc2c705f5b798
lib/kafka/protocol/message.rb100644004.94 KBd9e222ae1e3389f5b0c4abca58132796ea3de941d654950c76a1ed120f5e8b19
lib/kafka/protocol/message_set.rb100644001.32 KB08ad54297037d98ef3857f0ebb07ff79185637e9e8f1e65c1f6226dcc7b2c8e0
lib/kafka/protocol/metadata_request.rb10064400544 Bytes65021e045bcda6a52eb52be23eafee651a78cb702a84c3f83ac8b567ab6cdfff
lib/kafka/protocol/metadata_response.rb100644005.75 KB96f19bf868153fa35986883e8c7ef803b1d615a2346770661c716266a4188c11
lib/kafka/protocol/offset_commit_request.rb100644001.19 KB4cfbe9f48097d971dafd40a2c7d171c4e9cde770b5bb091cf83e5d507461488a
lib/kafka/protocol/offset_commit_response.rb10064400558 Bytesd7e3ebe35876dd7e62ef2d86007525746fc1f596c1acb3e5eadcb1fb5b41bfec
lib/kafka/protocol/offset_fetch_request.rb10064400678 Bytesad807b4393b15389b500a1d6a89550d7c47a6edcbf0b76ed87c2b1d14f8a1236
lib/kafka/protocol/offset_fetch_response.rb100644001.18 KBaae5c98108cbcd4eaa69f629eb81a574f6ebf25ad8057bfe51b44bf7dbe74dfb
lib/kafka/protocol/produce_request.rb100644002.37 KB77b33ff66ad58703f24c575de21591f0d57eb0ce2557e61e58c6ff3d0693942e
lib/kafka/protocol/produce_response.rb100644001.52 KBee0e2f61b77b61ed5ff9d40ad037d45a58e614a1f085774d6657e1eae5a4a9b0
lib/kafka/protocol/request_message.rb10064400632 Bytes384926355593975a9b4657b56ebfcb1b8e2896df50b1e8208a7e36a77e76e215
lib/kafka/protocol/sasl_handshake_request.rb10064400733 Bytes6a1159ed31bc3aba06fbdfe7eb3a67d4d3d784c605cbcd21a4257bf44b03a575
lib/kafka/protocol/sasl_handshake_response.rb10064400646 Bytes968ff014f54b27719edad0dcad8caee659120420b71b246f5c7c80d1d5f7f50c
lib/kafka/protocol/sync_group_request.rb10064400825 Bytes32c25ac7bad8161f47bf33ada4e62a527b2cb8bce5404cc74b180513b19b798a
lib/kafka/protocol/sync_group_response.rb10064400539 Bytes94ae14428fbed85055d61a30b61fdbebd37c7f5309f5dcd3c582bc216d094880
lib/kafka/round_robin_assignment_strategy.rb100644001.41 KB328da4832562b3c2a394e3f52b1090144e86a3aeaa4b876a81fd8c672bedcc02
lib/kafka/sasl/gssapi.rb100644002.01 KB42f8096e771d0eedecf2b1fc73ba3fce5246e23491b15e7489b1c0c3bee1cd79
lib/kafka/sasl/plain.rb10064400940 Bytesacec2ae312d83652752b252ca0645e412c5299762476fdbea46bdc9c1770ca6e
lib/kafka/sasl/scram.rb100644004.13 KB4244c110ae2f14521f5e451b3545a1acbe0fe2d9d601f660752b5753bf2fea04
lib/kafka/sasl_authenticator.rb100644001.47 KBa9e4607f837d1c3020456cce15eb2dfa4d5a0774845720c0951c53d2f9877153
lib/kafka/snappy_codec.rb10064400462 Bytes0c0a26c3def18fa3e9f704e822955f15afc4eef6de625482cb467b7add4138c5
lib/kafka/socket_with_timeout.rb100644002.86 KBb60f4acb77e93addf7894cf1e0ab264d4cd38ebf76252cd6015f297fe741ef53
lib/kafka/ssl_context.rb100644001.36 KBa5b03a211c804eae1e5766df400e7ce22fa02a34b0f3e1d932f8ac45954e15db
lib/kafka/ssl_socket_with_timeout.rb100644006.2 KB1dfb31052ca05b6af5c66435957150452a5f51ea18647efdf4f68dcd4c323f61
lib/kafka/statsd.rb100644009.41 KB3c701f689421a504aafcec137ddb092116aa2014e1f83c6dcc2a3efb4daac9df
lib/kafka/version.rb1006440068 Bytesfcace4dbfc2e30b6c14598802a1b652678b3a0b8612708ffe5bbce14c3d807a5
lib/ruby-kafka.rb10064400104 Bytes25d6544cc2344227f3c73e788ea1f897e2057f58917d3fcb072e0df68c5d1ded
ruby-kafka.gemspec100644001.88 KBda3656fdaabe80acbe1056fde021fabf67ea02185db379156ff6d98727cda517