ruby-kafka-0.7.0.beta1

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899494

number: 0.7.0.beta1

platform: ruby

spec_sha256: 873bbfe882bad658beda32c810982b20b4f830fc565d530c396bbacd739f5029

sha256: c3ddd6d1797753bb5c4f28f201adb6bacdfdb84859707daa15d3a59b2706cbf5

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

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

position: 27

version_data_entries_count: 116

uploaded_at: 2018-06-21 09:54:01 UTC

indexed: true

has_extensions:

extensions:

Gem size: 90.5 KB

Version Data Entries

Total: 116

Unpacked size: 348 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml100644002.43 KB5dff5b8e6cd094a07221ab8b16572774ef26a3f8ecc91149dd436307fa409eca
.gitignore10064400104 Bytesd7d42fff0538e1c089ce94148a5c59a50d4557246d72209feb58d5e58b8a26da
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644005.84 KB92c0ea049ab1a204471ef6b2d33af64fe6041acc5c80828035477bbe39cbdc15
Gemfile1006440070 Bytesbbf84bea967ac012444426fb7d35999ebb3e2fc9ceb7d76ba129e6466f1d8d2b
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440060.1 KB725720f73911b4d7ff0d2ae15f7cb9a9608f6da0f2cbe53b827102cee7615793
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.86 KB64fa440f5bfc7a05d093e7660c1acb19161ffa922931015d835739e3905a5731
lib/kafka/async_producer.rb100644008.34 KBe27d09064ce080d590b50f440924a3919370bbbea0b8969582c5fdc7804df563
lib/kafka/broker.rb100644004.22 KB4889684c1564ca542186042af90184ed3d3523e444b62eb348e883b24c59761c
lib/kafka/broker_pool.rb10064400884 Bytes66f56902ae80d587c564f69c397030bbcc71d8c7996f870c0cebe4c20ff45eef
lib/kafka/broker_uri.rb100644001.01 KBcb53169ff8a20dbe5f2af0d54ecb5727d27f914f9d4c57f85b8d97ab8153e402
lib/kafka/client.rb1006440024.1 KBb1052c4a83cae6792a64af3016125962a378bbd912755883e8379938467d9c91
lib/kafka/cluster.rb1006440011.6 KB773a0390c289309c7b055465100c851064801ebc84f37cb656f64baf9eb0d5da
lib/kafka/compression.rb10064400764 Bytesfb4e38bfe28aea8c58a36b1cbbfeeb10c43bc230eea8568b04c10176b02202de
lib/kafka/compressor.rb100644002.65 KBb9b7b4d63d38029557b8c7c8c9ac6096a1d413cd3436d40b6a14454c17289157
lib/kafka/connection.rb100644006.91 KBdaeb84702fb7b2a891ab3c9ba0d52b433b71600538ddb9abf98e077d2673237d
lib/kafka/connection_builder.rb10064400873 Bytesc61bdf2d70373387f0c5384840b4e96abff6848490c1710b6cf91e7d15f2b4a5
lib/kafka/consumer.rb1006440020.3 KBba6d2caf7a6c5c37176044cca224dd1b723e91abde2bc1955f4ec77f5478c18e
lib/kafka/consumer_group.rb100644005.17 KB8eb47afd8bac9275b025e9c8f526ffaa838ece80ab627e7a1987d83de4a44e90
lib/kafka/datadog.rb1006440010.8 KB24fd78f0650a751ed73f95a3eda1e4a706807e71919c2d0fd22aa4ebd74cae16
lib/kafka/fetch_operation.rb100644004.47 KBeccbef93ca1f9e69a8810bb4e325623c6d1326d9c6df9a037fab76a8bc64cba4
lib/kafka/fetched_batch.rb100644001.03 KB7f12ac23890a8c3cdbbbe0a8347a03c49b762a6745930208e698f27fc9af22ef
lib/kafka/fetched_message.rb100644001.04 KB4197888778089535f4d6b3cb20bb8c7471f191447b2a1ebc50f8fff58b9b70cc
lib/kafka/fetcher.rb100644004.5 KB91fd7fcd1f8626b9e8841dccfa438dc6f1cc354ec90520281d4c020e85a82ce9
lib/kafka/gzip_codec.rb10064400543 Bytesbef14b52c5127465add5fb9c3472a9d5fd32f91cb6064f6c3855592425b6e4df
lib/kafka/heartbeat.rb10064400363 Bytes72d707024bcc2265853771bf4e8a62b394cbe49e1cba6efc16de973bde968273
lib/kafka/instrumenter.rb10064400881 Bytese67d7c8f911ee529d0160993a406554a088ed0141e837598558bb1d38b86edf2
lib/kafka/lz4_codec.rb10064400395 Bytes9287f64e8e3ba6dcab1868ad7cebba284731200e907e9062653ac0075caf9cdf
lib/kafka/message_buffer.rb100644001.97 KBf06f28996ac8cafec311cff8e03932776cd17b4f322c8f2ecb375e76863f0faa
lib/kafka/offset_manager.rb100644007.97 KBe2b98ff6c7af608bca3027915018fa80f0bf5e19dff75c9f5e868e0fb5a2c54c
lib/kafka/partitioner.rb100644001.11 KBfbaed72feaafae2cfbbcc651be0cbad30ad90e76831a740b847f78b7c3bc5193
lib/kafka/pause.rb100644002.66 KBffa250fbc7c6fd9085f2709cf269774409a8edb591d9de9ea73082bb8a07ce02
lib/kafka/pending_message.rb10064400851 Bytescf64d6f91b69be4bde897886e3d209117c528a5178637a38e3e342796b89ef45
lib/kafka/pending_message_queue.rb10064400658 Bytes1665aa4ae63fabdddc881088c8557bd39cdf33cee35fd97b534024b26bdb2b65
lib/kafka/produce_operation.rb100644006.27 KBdee7d849747b03c23c82afdb8f7b886d671beb8492e6929ab6d419369c4b8876
lib/kafka/producer.rb1006440014.5 KB9fe70f59d6835443a7ef3e0d3f15e7bb07359e91c98f2037452666405a207ef2
lib/kafka/protocol.rb100644006.26 KBabc8f10951f84bcc9f5e763de1fc210c6db815530e3b7d38d8d489a1be473d53
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.rb100644004.04 KBefa6e8adae288d4c01c87858eb29493e7118e34b54881c9eea4fbb7198f8e9b7
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/describe_groups_request.rb10064400486 Bytes69ede56cc5820f192b3f8b16cbd10f2ebe6f5fc72b2e4fd98c9c3a7a36480415
lib/kafka/protocol/describe_groups_response.rb100644001.94 KB3c3f7d79a9fcd70728513d7c9f5b57d6f2276e9d51676c2ce6a82eb4d3bc3fa6
lib/kafka/protocol/encoder.rb100644004.41 KB28ba1da7254c6c44d75afc5a9b8e2f83af6ffeba34e493c6e46773fd3bd944e6
lib/kafka/protocol/fetch_request.rb100644001.74 KBb09905b317578ae24097e31654297e19c3ec565f3ce34c7cff846807fe4367dc
lib/kafka/protocol/fetch_response.rb100644003.41 KB1071a8ad72cd1dfbdd4c17659cfde0f7a961a31424522431558b89ed30054a1f
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_groups_request.rb10064400328 Bytesbac584b49255bfede6724945277a766b919e303c8fd4cac8739054bc81304b88
lib/kafka/protocol/list_groups_response.rb10064400769 Bytes6b07fc35ff25e7ff826116fabad7e31f00384ddf1895082079d39693268f2883
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.58 KB695f3678db02410db2741f268a40ddbd13a3a82249976767804dbd8fdbb2e7af
lib/kafka/protocol/produce_response.rb100644001.52 KBee0e2f61b77b61ed5ff9d40ad037d45a58e614a1f085774d6657e1eae5a4a9b0
lib/kafka/protocol/record.rb100644002.17 KBfef153d5bfa2e141cc8409f03bdce0055f8ad4cbc69ac14be4005fd590e746f9
lib/kafka/protocol/record_batch.rb100644006.49 KB41ad6140ccdd27ea102e5424ceae9c7b9668bb33db467e9e91122f04399bc4f2
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 KB7c91b22965ed85e4480bac648056e5ad920dcabbc335b15298d8e62fec1e54ce
lib/kafka/statsd.rb100644009.41 KB3c701f689421a504aafcec137ddb092116aa2014e1f83c6dcc2a3efb4daac9df
lib/kafka/version.rb1006440074 Bytes94d39385e2b4565250f9a1e3eb369502dd7f7739e6e089c66bf2b0b4de415ab1
lib/ruby-kafka.rb10064400104 Bytes25d6544cc2344227f3c73e788ea1f897e2057f58917d3fcb072e0df68c5d1ded
ruby-kafka.gemspec100644001.91 KBc3361bdc8f1fbd0538d26dc1929bb377e118a0a87e09194fabf8c8db103979eb