ruby-kafka-0.7.6

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899508

number: 0.7.6

platform: ruby

spec_sha256: d59dcce31629b5d680596a2f3a0e431addba30fb013d9b0ea3e0ed6a511960a0

sha256: ab994195b9979a7bbff8e4fa01f32cb40caa4b6a4b7317b9354227fed536b12c

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

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

position: 11

version_data_entries_count: 130

uploaded_at: 2019-03-14 09:56:15 UTC

indexed: true

has_extensions:

extensions:

Gem size: 102 KB

Version Data Entries

Total: 130

Unpacked size: 401 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml100644005.87 KB4c4bcbc0227d11f71647dcdcd7bba4e4cd888b27bfb35797b4e0de091f98ca4d
.gitignore10064400120 Bytesd703c97858d7b978d6bcb91b08f34160f966d1daa4a6d2a53dcb17c646802a0a
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.ruby-version100644006 Bytes99600f6a7bfe6c33ebd1a2518f44a861a67afc40c25da42bc622595716529584
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644007.86 KBc9c00460c589b2c809343b959212c86e13008b7d7d4016fc571220ce761d809f
Gemfile1006440070 Bytesbbf84bea967ac012444426fb7d35999ebb3e2fc9ceb7d76ba129e6466f1d8d2b
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440062.1 KBc510ddd8d84978f31fd9fc76d06d7a592b41a430fd9800e06606ba6857b12119
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.rb100644009.1 KB955061dedd79ab741d19d96d2702d2c96ac45c45ab824a6aa2f8290a7461eb12
lib/kafka/async_producer.rb100644009.18 KB32736a6311ead1481463f2c578595be9e3c58b8a87c3fcf1e7de1e34b0115353
lib/kafka/broker.rb100644004.63 KB41fdd794dd804ae0fab18e9252a16833c1d1655ad187f1de211c7bcf476822b8
lib/kafka/broker_info.rb10064400305 Bytes046da90a62c8a643812e3007ffa0a3a4865c5e95ca0d21e2327de49eea574e0c
lib/kafka/broker_pool.rb10064400902 Bytesdcf47ff4e1885447a46b3d5ff6590949470fcb8b79bc773fd9f649cd0dfff93e
lib/kafka/broker_uri.rb100644001.01 KBcb53169ff8a20dbe5f2af0d54ecb5727d27f914f9d4c57f85b8d97ab8153e402
lib/kafka/client.rb1006440026.5 KBd530a9690c35948dd5d7dc1d05c58187545ee5477f3980d61b2f2ab27143eb3d
lib/kafka/cluster.rb1006440012.7 KB895f8781b2fb5d67934f0c8e0a8b8ab0a2b5d1ac96d57ffcd37368452172dda2
lib/kafka/compression.rb10064400764 Bytesfb4e38bfe28aea8c58a36b1cbbfeeb10c43bc230eea8568b04c10176b02202de
lib/kafka/compressor.rb100644002.65 KBb9b7b4d63d38029557b8c7c8c9ac6096a1d413cd3436d40b6a14454c17289157
lib/kafka/connection.rb100644006.99 KB4c5b1cc5a4598bd9cb5d0f86d26dd31f7f65398b8ea8c2346d36c03cf41efbc8
lib/kafka/connection_builder.rb10064400891 Bytesb1ef4a357fa81b27fe1064959c9911e64771bdf1f4805a23f37abe9e039f9ba2
lib/kafka/consumer.rb1006440022.1 KB5738a08ba683cf8a44f4e4f0378cd5c21946c95bdb41200f61a6dfa0d6038450
lib/kafka/consumer_group.rb100644005.7 KBa3f5fafe6931bc3bafa5d8b45a9c063fa45d28f4a3c8fccf25a42014e17418dc
lib/kafka/datadog.rb1006440011.5 KBf25597a2040c7aa9dc9188851b0e0bebcedf35d19ad80858d10ab7da1180782f
lib/kafka/fetch_operation.rb100644003.4 KB589e23a869bd4c8c039ab9dd4ac4aeb70d91b3c4cb570a73ba3e7774ba3c1609
lib/kafka/fetched_batch.rb100644001.07 KB9d1df22857bc8ae23fc7f40f36ffd2c622902210985a6aa9f4d33be3da34f4b3
lib/kafka/fetched_batch_generator.rb100644003.76 KBb9aa1ea469d9d92ddf9f54be853ec32fbc59e63436b66c3ddd1db50dd1890ef7
lib/kafka/fetched_message.rb100644001.04 KB4197888778089535f4d6b3cb20bb8c7471f191447b2a1ebc50f8fff58b9b70cc
lib/kafka/fetched_offset_resolver.rb100644001.25 KB61fdcd04d76e4a00f5577e3e226091c2ecea97d11edfe28a7ff1ac0cb002d718
lib/kafka/fetcher.rb100644006.01 KB1f7990fc7891b06b7c54295895c439d7945d49e777c25ddc8c96a9cfb3c61e30
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.99 KB7992719984865af33c61b301e2a28648b4ee42013caf2aa05b14d830fc817c78
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.92 KB7163f1143ad9a8f75e5bdcdf62708778305a1d7f9699fa87ecc819a47ccdd8a1
lib/kafka/producer.rb1006440017.7 KB5ab1a99f40931d4182463e1e94fd2987ae9aefb89cf7ddea3e783418d8b88fcb
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.21 KBbdc27a186693ab39892caf482060602623764665d87f365b334197bbcda37b27
lib/kafka/protocol/request_message.rb10064400632 Bytes384926355593975a9b4657b56ebfcb1b8e2896df50b1e8208a7e36a77e76e215
lib/kafka/protocol/sasl_handshake_request.rb10064400745 Bytesbda905eb81e09ac1edea9eebe3b65a89d86e7eb58e44bf9de4f03132836fa306
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.03 KB571c364d59f8237dcb8a1c7e45a3b184f3fb46683b8057088a091d1882097b3f
lib/kafka/sasl/oauth.rb100644002.31 KB1efc0f91c458557a26b37e139a5a93403cee3d3c4274cf00272b5be732d955b3
lib/kafka/sasl/plain.rb10064400958 Bytes23d933e284812f41a7e1399247e612ea4c785a163e8fee800303ddd8ac832fd3
lib/kafka/sasl/scram.rb100644004.15 KB02168629a6b1240093221ff634b7a57ed6a60a028cf33acc6765836d1fb092b0
lib/kafka/sasl_authenticator.rb100644001.68 KB10a03f4b25f843972290ade9634e2c36a32d93f4863371a90f7c116b69e29566
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/tagged_logger.rb100644001.6 KB4c268b5b2032732d124b5d53b1ccc0e513a74751d3431d254c1b7c0695918529
lib/kafka/transaction_manager.rb100644007.52 KBe487af1cd55aa8f200edecebc309be76a3f115888788fc9a7e225de6abb969a0
lib/kafka/transaction_state_machine.rb100644001.85 KB114da700128b9c2c2e30e1e5ed24a78a2481b2cd6c5b1c8d587b3e4b3c707825
lib/kafka/version.rb1006440068 Bytes067eaf23626c5ee8ba3dfbca85f734393aac621b56da3bb5ddf6fdd7a5b09c2b
lib/ruby-kafka.rb10064400104 Bytes25d6544cc2344227f3c73e788ea1f897e2057f58917d3fcb072e0df68c5d1ded
ruby-kafka.gemspec100644001.92 KB27cd862640373012b6a030776691158acb81ad0fa16656058bfffed042472b63