ruby-kafka-0.7.5.beta1

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899507

number: 0.7.5.beta1

platform: ruby

spec_sha256: 6e4875c8afb5091ddd6937d0d784b3f71074845534424e3f45b6402b8603d384

sha256: 92f730fd6cae5bd01528af1c4fa515839f1a6eae38fb60e71fc7ec3697794b72

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

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

position: 15

version_data_entries_count: 128

uploaded_at: 2018-12-04 09:55:36 UTC

indexed: true

has_extensions:

extensions:

Gem size: 99 KB

Version Data Entries

Total: 128

Unpacked size: 390 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml100644004.76 KB9ab2ce72e9a449a5bfc09c964d21eecbe114c3dd0733cd27f9a3dcc813aab239
.gitignore10064400120 Bytesd703c97858d7b978d6bcb91b08f34160f966d1daa4a6d2a53dcb17c646802a0a
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.ruby-version100644006 Bytes99600f6a7bfe6c33ebd1a2518f44a861a67afc40c25da42bc622595716529584
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644007.57 KB0e15dc5aa24d43b5112d166eabc8e435f6156b26ce3519085a61635df947d049
Gemfile1006440070 Bytesbbf84bea967ac012444426fb7d35999ebb3e2fc9ceb7d76ba129e6466f1d8d2b
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440060.8 KB9786004e00976ae75b1929df92db7c525656c89c6642564cc7f4c3589d3f7f25
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.rb100644008.96 KBac1b5be7722ef2956173a56537cf074d04bcf09d911627ca1c3a4972b8ea31c7
lib/kafka/async_producer.rb100644008.46 KBb472d1a1870d81c90032a409666deddba02823a766b12fbb38cd17e99d989b6e
lib/kafka/broker.rb100644004.61 KB658c42236642b2620ef2d9030d950fb79db1091122fcfd0037cd54183119cbfe
lib/kafka/broker_info.rb10064400305 Bytes046da90a62c8a643812e3007ffa0a3a4865c5e95ca0d21e2327de49eea574e0c
lib/kafka/broker_pool.rb10064400884 Bytes66f56902ae80d587c564f69c397030bbcc71d8c7996f870c0cebe4c20ff45eef
lib/kafka/broker_uri.rb100644001.01 KBcb53169ff8a20dbe5f2af0d54ecb5727d27f914f9d4c57f85b8d97ab8153e402
lib/kafka/client.rb1006440026.1 KBb870a46cc1722a98947931b7e217ff3c522ea3af9c1f804f83c70a9442c7e1dd
lib/kafka/cluster.rb1006440012.7 KBd4d97b7ab8044a0d322b8132686133dc5783d1306b0712d4f3a98cd368eea40a
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.rb1006440021 KBb60c3635de046c7ad5f4444e339724d05ee075c75b86319d60640fee96ca91f4
lib/kafka/consumer_group.rb100644005.37 KB2980db45a5370faf8aa120d3662e2c33fb51e1770abc05725a18d9df99d0df60
lib/kafka/datadog.rb1006440011.5 KBf25597a2040c7aa9dc9188851b0e0bebcedf35d19ad80858d10ab7da1180782f
lib/kafka/fetch_operation.rb100644003.38 KB9246546353a8ec5f99970ebac0cc9c8c170c3ff766a713bec3eeae74200ce40e
lib/kafka/fetched_batch.rb100644001.07 KB9d1df22857bc8ae23fc7f40f36ffd2c622902210985a6aa9f4d33be3da34f4b3
lib/kafka/fetched_batch_generator.rb100644003.74 KB336a1138669d5197fd31a3631f754f17e4faa7d0b82d207b35bca13912730914
lib/kafka/fetched_message.rb100644001.04 KB4197888778089535f4d6b3cb20bb8c7471f191447b2a1ebc50f8fff58b9b70cc
lib/kafka/fetched_offset_resolver.rb100644001.23 KB4bc094e7117d140d6b43bf97df59a0599fe5389ffcff76166f6046b334f539f1
lib/kafka/fetcher.rb100644005.92 KBd99af66b6e6a85710495285b09b387793cdae47a90b33dbfeb4c2ac2870cfaba
lib/kafka/gzip_codec.rb10064400543 Bytesbef14b52c5127465add5fb9c3472a9d5fd32f91cb6064f6c3855592425b6e4df
lib/kafka/heartbeat.rb10064400618 Bytesdab0eeb599f04eb976600a7b088e143557b951c0dec597a028f73f1eb0a2bf21
lib/kafka/instrumenter.rb10064400881 Bytese67d7c8f911ee529d0160993a406554a088ed0141e837598558bb1d38b86edf2
lib/kafka/lz4_codec.rb10064400395 Bytes9287f64e8e3ba6dcab1868ad7cebba284731200e907e9062653ac0075caf9cdf
lib/kafka/message_buffer.rb100644001.97 KBf06f28996ac8cafec311cff8e03932776cd17b4f322c8f2ecb375e76863f0faa
lib/kafka/offset_manager.rb100644007.97 KBcc1b536bbab65dd1032686c1f2a8f8abf85dd180be795ae8bf45a6767535b2d5
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.rb100644007.9 KBf612cda86bb5029bc02a2e4a4452bb083e3a8c449b9bd432dfedec4fef84451e
lib/kafka/producer.rb1006440017.5 KB6c2232b688ad2e3693b067bb410931ee3acfaf7b1b4ae442e74799e7eff3be70
lib/kafka/protocol.rb100644007.97 KBc8f904b85bd7dd8ec7bba3ad92ba2b2b865787a6635b57c32f892305bb943953
lib/kafka/protocol/add_partitions_to_txn_request.rb10064400896 Bytesf81733c655b4fa45f34391f49eb2e4a23c0184701ea8f012beef59a653c0a4bb
lib/kafka/protocol/add_partitions_to_txn_response.rb100644001.03 KB93e8934a4d1eec97881a2e01c90c993096cb4b2a5229ab2434727fa51efd1887
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.rb100644003.99 KB9236d52475f1ec33c7b438be193380b72c855931298b457df8a430376121635b
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 KB2161896f36e464ff498747a3f584f6a5d12dc12c4f2adf146de415da1713bb75
lib/kafka/protocol/encoder.rb100644004.32 KB11d60a2a9a51b158836019324234f988fd0b9be8c6b0d9513060e7709ce9104c
lib/kafka/protocol/end_txn_request.rb10064400707 Bytesab1bc233c276a568c4a15c250bd61360ee28d72010fd1c811544bcae65110b7d
lib/kafka/protocol/end_txn_response.rb10064400368 Bytes907b07d8ba392f47b9e34014db0fffd6c7c2a270a1398993075c8f32de86b080
lib/kafka/protocol/fetch_request.rb100644001.83 KBfbd178a57bfd55b927876aa7a2c7d6ac76a2a71ed16d6f34b5da8581de7e43bd
lib/kafka/protocol/fetch_response.rb100644004.02 KB8f3eaf89b65b7cdca5e25f65b18b084ab656721032e2b1eaa0c375db46df2fc7
lib/kafka/protocol/find_coordinator_request.rb10064400569 Bytesf41289d849f26d6344ec23eb8d3cd993479395cc02403372b41b74ffaba21f00
lib/kafka/protocol/find_coordinator_response.rb10064400826 Bytes48b02212ebf1ac1981a75f8dadc8f1ade2cfdc4ffdd4ff83786625fff1646e06
lib/kafka/protocol/heartbeat_request.rb10064400551 Bytes624e3edcca15102e4a2a600cfb60f0affbc904168aa92411b488e4fbf520bb08
lib/kafka/protocol/heartbeat_response.rb10064400297 Bytes465c33fb4ff768b8ded8014128637cf4193dbff313c7060cb305519b6e35ec30
lib/kafka/protocol/init_producer_id_request.rb10064400591 Bytesbfc304e0c08d6c313e3102328c299b13819744be6bc81490506e6dfe38134321
lib/kafka/protocol/init_producer_id_response.rb10064400687 Bytesc7be202368f4209d3d24b3ed18096445bf6de91ce51d0ebb877cd0b142309baf
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.24 KBb72dc90adc4c1c1b1e29c4a3d4d4072fbd14ed502435fc86b8ae18312fa30276
lib/kafka/protocol/list_offset_response.rb100644002.18 KB3e106b601752a99853b720964090bce40870f7ba7d10e64c11c2c68f1854807b
lib/kafka/protocol/member_assignment.rb10064400977 Bytesb14d0381c94c08eb096b45d01304300ba00a73cfb4ef7fe079dfc2c705f5b798
lib/kafka/protocol/message.rb100644005.11 KB71e2a0086271728ff3ff6ef67631ac9871eb6247dea6f13fe424668d235d833d
lib/kafka/protocol/message_set.rb100644001.32 KB08ad54297037d98ef3857f0ebb07ff79185637e9e8f1e65c1f6226dcc7b2c8e0
lib/kafka/protocol/metadata_request.rb10064400544 Bytes65021e045bcda6a52eb52be23eafee651a78cb702a84c3f83ac8b567ab6cdfff
lib/kafka/protocol/metadata_response.rb100644005.55 KB776248db5e2482cfee42d03ac2b8b6a383cd3c8bf91a6567b16ba1a6f87cc3ac
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.43 KBa4f5c89fddf96b5db47731ef2b7a790f713bc6693c6a415a2a6d39e68e1d424a
lib/kafka/protocol/record_batch.rb100644007.06 KB0daf421795b5c7e5c11c96b3a795f686afb2abe5b9824c73a9c857bdf5710827
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.55 KBd9fe1405bcb3aec7a6a3b2f595f4893034d5e2c47455a00ccf3c2f7c67e3d448
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.rb100644002.6 KB1c73fc4cac24f1e02d1993e81133f27b498978437b93ddb7ee09679e2005bfa7
lib/kafka/ssl_socket_with_timeout.rb100644006.2 KB7c91b22965ed85e4480bac648056e5ad920dcabbc335b15298d8e62fec1e54ce
lib/kafka/statsd.rb100644009.79 KB47caddc340189a9ca0d6cc22b9c6116cd1aa1bd6d37a7a11529539db61a4520a
lib/kafka/transaction_manager.rb100644007.51 KBd863318be01dfabaab948bf829b8841df0dfff308e282c1966a80fe1fa9be28b
lib/kafka/transaction_state_machine.rb100644001.83 KB77c4ceb8919aa2f6ade0536a17353dca3ef73b926985d910fdc8b21c4e0c90b8
lib/kafka/version.rb1006440074 Bytes900b09caea932425432ec3eb5255b374254e48d38df934ee6e7d04ef5f4312e9
lib/ruby-kafka.rb10064400104 Bytes25d6544cc2344227f3c73e788ea1f897e2057f58917d3fcb072e0df68c5d1ded
ruby-kafka.gemspec100644001.92 KB27cd862640373012b6a030776691158acb81ad0fa16656058bfffed042472b63