ruby-kafka-1.2.0

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899517

number: 1.2.0

platform: ruby

spec_sha256: 96600e58195c6215ad29bb47fa2718f671fc5f6f0db3f68ce07a96f430c710b2

sha256: 40c95518c2ce3f84c59566ebed3413555f4a74a91bf306c7acd92f0082e36a5f

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

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

position: 3

version_data_entries_count: 138

uploaded_at: 2020-08-03 12:34:31 UTC

indexed: true

has_extensions:

extensions:

Gem size: 108 KB

Version Data Entries

Total: 138

Unpacked size: 439 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml1006440010.3 KB554fa926118aa768670644bf340ea82013ddbcdafc3da9869814983ca710d366
.github/workflows/stale.yml10064400500 Bytesb82d9869c465092d1e5c2282aaa61216ad807fe2def0032cae4407ed07e34f16
.gitignore10064400120 Bytesd703c97858d7b978d6bcb91b08f34160f966d1daa4a6d2a53dcb17c646802a0a
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.ruby-version100644006 Bytes9927e4392d0216300aa135317885771db7cb72706f05e6a3c1e9ff63194b8cae
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644008.9 KB25826854b43f17d47794cf30b3e976071d2ea5d7faf203ffd8142f79a3f5e7be
Gemfile1006440070 Bytesbbf84bea967ac012444426fb7d35999ebb3e2fc9ceb7d76ba129e6466f1d8d2b
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440063.6 KB1f6556714a517f9e3bb658e2786f5553539b1fa940f9dd89575758290e4979ca
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.28 KB95a4638ac541d8267f1c6b144e13542ad77c54b5385815692ae688aa260c24ee
lib/kafka/broker.rb100644004.9 KBf655d5c66e4a09a4d37b277f386d60bbfacd9a857f85cd10ebbf0355157bef88
lib/kafka/broker_info.rb10064400305 Bytes046da90a62c8a643812e3007ffa0a3a4865c5e95ca0d21e2327de49eea574e0c
lib/kafka/broker_pool.rb10064400902 Bytesdcf47ff4e1885447a46b3d5ff6590949470fcb8b79bc773fd9f649cd0dfff93e
lib/kafka/broker_uri.rb100644001.01 KBcb53169ff8a20dbe5f2af0d54ecb5727d27f914f9d4c57f85b8d97ab8153e402
lib/kafka/client.rb1006440029.1 KB5f5671d43331e53a3353314b20f02c17501e7630b23fc92554fe29e26ba1b600
lib/kafka/cluster.rb1006440014.3 KB8f5a26fa190a244ac24cb8480fb6992917a95dc2e41ec3db97db9d3fc174b6cb
lib/kafka/compression.rb10064400881 Bytes77bf21d34d9491a11bc86d651cf9d5f1b2895d9385530b7777a39fa3a12cb4a6
lib/kafka/compressor.rb100644002.67 KB81c9b25d811fd26b1758974aee38fd39356d51283e41f1444d5664b47f1a4547
lib/kafka/connection.rb100644007.04 KB971f777f8aeb7549fc133148efc1b419badacaa8dc71d40c8e9db6ebec72236a
lib/kafka/connection_builder.rb10064400891 Bytesb1ef4a357fa81b27fe1064959c9911e64771bdf1f4805a23f37abe9e039f9ba2
lib/kafka/consumer.rb1006440024.1 KB4bc0eda635de23624f5234f37b1f398c0f0cec6d39c6c11c5aadba0b3aa9c1c6
lib/kafka/consumer_group.rb100644005.97 KB8509480530852b00fc1bc3f91cee2f814106e63956c741eaf2215572f43e40e4
lib/kafka/datadog.rb1006440011.6 KBd1eeb7eb27e8a9c8e63d726e6c3d7e828d78643e2f7119bd5bd115afa86a7287
lib/kafka/fetch_operation.rb100644003.4 KB589e23a869bd4c8c039ab9dd4ac4aeb70d91b3c4cb570a73ba3e7774ba3c1609
lib/kafka/fetched_batch.rb100644001.18 KB9f0e922a53a6888a6377c4fef32ce5d4d6c54baad1449ba6acda02cf7972abcf
lib/kafka/fetched_batch_generator.rb100644003.96 KB9f61bbc6888fa9c42dae8da249fb30c58fcef26d284575d8b8f095d4617cf0a1
lib/kafka/fetched_message.rb100644001.04 KB297a9e034f975035c3f5bbcc707235791b801a27a9fcfe92f855ed9c4707605d
lib/kafka/fetched_offset_resolver.rb100644001.25 KB61fdcd04d76e4a00f5577e3e226091c2ecea97d11edfe28a7ff1ac0cb002d718
lib/kafka/fetcher.rb100644006.11 KB6f9c5c1167ba0e0c5912006e53b0e1075cf29637dd186baa4c57307a6c83b1b5
lib/kafka/gzip_codec.rb10064400592 Bytes84cc342cfaa94bca2cff8ba51567f2535aff0fb8492a99f128d909e42efcad64
lib/kafka/heartbeat.rb10064400618 Bytesdab0eeb599f04eb976600a7b088e143557b951c0dec597a028f73f1eb0a2bf21
lib/kafka/instrumenter.rb10064400881 Bytese67d7c8f911ee529d0160993a406554a088ed0141e837598558bb1d38b86edf2
lib/kafka/interceptors.rb100644001.2 KB8c4a40f16d3e4cebd5292953a2008e69e623962362b658e646ff2213acbff2c9
lib/kafka/lz4_codec.rb10064400444 Bytes9580cb1595e238c68c4ec750906a46238b3eb061d8dcca5d2c0e78133f851d1a
lib/kafka/message_buffer.rb100644001.97 KBf06f28996ac8cafec311cff8e03932776cd17b4f322c8f2ecb375e76863f0faa
lib/kafka/offset_manager.rb100644008.45 KB9e9768b60b9bac256c73c953b14c39379ac24371900626ba9f5f6ec2f1df41ae
lib/kafka/partitioner.rb100644001.1 KB366c8c75c16529885501ad03b8a5fc027ca3975609bdf3dc353d6014c01da6f0
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.rb1006440018.9 KBee974db1b6cecc78d2143d153f214e6b02236fcd7c593c0e548e8c677c3af8af
lib/kafka/prometheus.rb1006440014.8 KBd4151e4de4405b2bf4e98cd39d7438fad4dc10543018c44c73f8d32851796baa
lib/kafka/protocol.rb100644008.35 KB1cb7e6731929342d5c460bd88fba845093acb6d5fdafc857923d4e68493b7b0f
lib/kafka/protocol/add_offsets_to_txn_request.rb10064400704 Bytes500710fc2f75d52e9218345cf407a4c2329f39076db56f1c34a569b9366cb1f6
lib/kafka/protocol/add_offsets_to_txn_response.rb10064400348 Bytesd8aa471280d1c686badc0fa9f4bf73c4130011192bf0519c4d4c1131f442cee8
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.21 KB67653095b3da32630123e61d97dcdc6bc0a256b12d686e067026bdcc8c2e4e19
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.56 KBafecd86e42d92e0a665277215d55d366433e40c19a431483738b713fe10ed190
lib/kafka/protocol/offset_commit_request.rb100644001.19 KB4cfbe9f48097d971dafd40a2c7d171c4e9cde770b5bb091cf83e5d507461488a
lib/kafka/protocol/offset_commit_response.rb10064400558 Bytesd7e3ebe35876dd7e62ef2d86007525746fc1f596c1acb3e5eadcb1fb5b41bfec
lib/kafka/protocol/offset_fetch_request.rb10064400829 Bytes44959c16e89d05eecb46580b5ba012ea0a4548358d21e9c10f83b2b8fe21e33b
lib/kafka/protocol/offset_fetch_response.rb100644001.18 KBaae5c98108cbcd4eaa69f629eb81a574f6ebf25ad8057bfe51b44bf7dbe74dfb
lib/kafka/protocol/produce_request.rb100644002.71 KBe5b5679e4e17a3aff9eed5efe26239fe34c479d33c0eb3461d3e10a318de7330
lib/kafka/protocol/produce_response.rb100644001.52 KBee0e2f61b77b61ed5ff9d40ad037d45a58e614a1f085774d6657e1eae5a4a9b0
lib/kafka/protocol/record.rb100644002.43 KBa4f5c89fddf96b5db47731ef2b7a790f713bc6693c6a415a2a6d39e68e1d424a
lib/kafka/protocol/record_batch.rb100644007.28 KB89499c5121add2bc06854e9cbe051837ced97faa2c4176222c14237dccc8a9f6
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/protocol/txn_offset_commit_request.rb100644001.14 KBb265a8887947866863af2b15fe000845334c543ca57a8312af928a18f2b7e190
lib/kafka/protocol/txn_offset_commit_response.rb10064400347 Bytes5bd6117fac7491cb7e9ed40f079c6e659e6f9f7ced73dcf1e16cca36fe868323
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.25 KB158be6eee3dcf3e364c40a1708fcac3f84036dee558ce5e2159cda8aa8e19844
lib/kafka/sasl_authenticator.rb100644001.68 KB10a03f4b25f843972290ade9634e2c36a32d93f4863371a90f7c116b69e29566
lib/kafka/snappy_codec.rb10064400511 Bytesa56725f97432414856cd6e1495e7f8c1a04185cc41598cf3a0c079df058ae21b
lib/kafka/socket_with_timeout.rb100644002.86 KBb60f4acb77e93addf7894cf1e0ab264d4cd38ebf76252cd6015f297fe741ef53
lib/kafka/ssl_context.rb100644002.84 KBa68eb9a3dff8c5c334f62ace4b844ba29702ff3709518ea4026b8a743add6269
lib/kafka/ssl_socket_with_timeout.rb100644006.24 KB8b786a59d40ff702323f05c3df39b0abf327fdc8873af38b2fce35589858638c
lib/kafka/statsd.rb100644009.79 KB47caddc340189a9ca0d6cc22b9c6116cd1aa1bd6d37a7a11529539db61a4520a
lib/kafka/tagged_logger.rb100644001.74 KB4170da76e278dbfce23d39bd129fc561f91697406f7b15e10eb3ea8a8db5ae4c
lib/kafka/transaction_manager.rb100644008.28 KBd330967cb060302f2098d730e0db6f3b22c8dd267e39dcad3703c69dc00f44a8
lib/kafka/transaction_state_machine.rb100644001.85 KB114da700128b9c2c2e30e1e5ed24a78a2481b2cd6c5b1c8d587b3e4b3c707825
lib/kafka/version.rb1006440068 Bytescf911cdc804be74f5f298d57602fafeb7d6f718ffba56ae180eb90fa8ac34cf0
lib/kafka/zstd_codec.rb10064400460 Bytesea9e94bbe9ae0ddf2e659e3594bed8cccb51da91f7d2147b7c47a0d9e3f27ad3
lib/ruby-kafka.rb10064400104 Bytes25d6544cc2344227f3c73e788ea1f897e2057f58917d3fcb072e0df68c5d1ded
ruby-kafka.gemspec100644002.04 KB0cca2111eb5606668ddd9f87567b2326ee1350e2065e62ac85f162064f7e660a