ruby-kafka-0.6.0.beta3

https://rubygems.org

ruby-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 899479

number: 0.6.0.beta3

platform: ruby

spec_sha256: 9bad4488b1473bb1422ed76c0fa77d3650b42f9a5b1487449f39d12ca7e7b1a6

sha256: cac894f1c61e429d98200bd91b122b082085c5cb880aed066eedc1e82b1f85fc

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

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

position: 42

version_data_entries_count: 109

uploaded_at: 2018-04-24 08:25:22 UTC

indexed: true

has_extensions:

extensions:

Gem size: 85 KB

Version Data Entries

Total: 109

Unpacked size: 319 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml100644003.53 KBae576efab08afa7c61f743efeb552d8bbc4c046f3aa628241060661e0ba78349
.gitignore10064400104 Bytesd7d42fff0538e1c089ce94148a5c59a50d4557246d72209feb58d5e58b8a26da
.readygo10064400347 Bytes85a5128a8214b91154d77ec394f16136d5d901be6c971c6be9fba226bec5f911
.rspec1006440053 Bytes06245e25d7cf46b4fbde27b5faa0df0d4110e11918eeb5848de4ab2aff897b59
.rubocop.yml10064400816 Bytes6801c9c8167e31ba4feececccbd86e4dbd34a613554b689647d783da3b7593d0
.yardopts1006440062 Bytes9413f9aa648bbcb62c0e189be5423c8713056d271d1d3a2e1249ded204bba876
CHANGELOG.md100644005 KBb0859f4b1860077a7e47cef9ee3a59c9c09a7b02013b4a540a33bdc43ed2f547
Gemfile1006440039 Bytesafe937ae0b605332cd5f9bfbd40d488faff2b9cd5bdd2a6f75fb3107704a196f
ISSUE_TEMPLATE.md10064400491 Bytese802f067f5775efc8c1596299c5d9472e6a8c9fb3c388f13606a08eb945eab38
LICENSE.txt100644009.93 KB59899c6091b540582ed617e8eeaac4919dc985ccfc35459ee9752b699be5205b
Procfile1006440084 Bytes5f3620b9c19d53563d4943d054ffea8a8f935179b787c466f8ad69ec494085c1
README.md1006440060 KBa5a473346285b289c9ac613ed3180e2285418d5923ef588ef17f9afaaed72054
Rakefile10064400114 Bytesd0726d260349476762de87bdd5c451c7bfe6e0e47fe09df9f011e120f1fd316b
benchmarks/message_encoding.rb10064400401 Bytes0d0428a28bbb23548d858d5da8eece31c1f6d2cbde1e772480ccf4b2d33b3f2d
bin/console1007550086 Bytes6e7cdf8cdc22cf29f16f4261589138eb0cd4e9f88a018adf9767c797fba13b38
bin/setup1007550058 Bytesdf7862c507aa40dc48aa06b34a22c87d93bcc4d15b6b2a5295c944f218e3a50f
docker-compose.yml100644001.02 KB36c6d99c1cbfc0a3a60c2fd1f3919a603c95a36eeec4b39f7337e670bd1e7241
examples/consumer-group.rb10064400708 Bytesfbde5847dde71c801fab43b7172f6e3faea6cbf74b5e41a213a31da48985a7fb
examples/firehose-consumer.rb100644001.32 KB50b2116bbb92df58705f6f1858c8c1baa1321e39ae981c39482211bcbf31b714
examples/firehose-producer.rb100644001.16 KB946acc8aa21b964c363284147bbf92ac2a73f3457a92073a2b043145c0443ef3
examples/simple-consumer.rb10064400822 Bytes0223310c8440078bb6848dd358a92b1c927457881c77aae3ada88340247c2dc3
examples/simple-producer.rb10064400864 Bytes0286681f6a6ef1d7892f3852ff961f5baa7c510729e996678d1868589ef03f85
examples/ssl-producer.rb10064400985 Bytes34cfa028e66c812507e178b7bdb0c0ae9c00c277ec5444d41ba0bcbc448315e7
lib/kafka.rb100644005.7 KBffd144b7eca07d67e23afb9433a07dfcb05ff47c86ff13d5ba55e540d25fb7dc
lib/kafka/async_producer.rb100644008.15 KBe5e30c3910cce46e2cb4efabc9763ddfb59abce0b1695bdbd0c3ee6ce91356bf
lib/kafka/broker.rb100644003.96 KB02059ee06db4cc59a3f4aef881f3610f3a43e8694d6cf47fa096e10dce8fc5e6
lib/kafka/broker_pool.rb10064400853 Bytes805895a56308fbcb02519e664eb399aa1bc08d28935c9d631c772865c7042d91
lib/kafka/broker_uri.rb100644001007 Bytescd066604401898c0af2d92947978cbca34fd95644268e88e2436c09fb1c213ad
lib/kafka/client.rb1006440023.2 KBe8642b4bc36398bd7c1212d122f51f6c8363a0ede2be1e113ff133dce70952f3
lib/kafka/cluster.rb1006440011.1 KB5d5ad6fe3294091ecd6423f97dca43b785f147754cfadb3c0762715ed0e7ceb6
lib/kafka/compression.rb10064400733 Bytesb83ef6aa3068d03b5909f0effeff4a600359c9a4737e343b531b5de0735e81bc
lib/kafka/compressor.rb100644001.96 KB44b43c6d89256458d45455ec924c869484fe72ede11cf3be1e5fc42e9a7d856b
lib/kafka/connection.rb100644006.88 KBda66f03c83f4737ee7abc67957bcbbcd927b5ed971c7c4f10faf6332f87197e7
lib/kafka/connection_builder.rb10064400842 Bytes443ed97a83bd5ea5dd848afafc3703fb3a443daf9190f41a268541baa5ebbd31
lib/kafka/consumer.rb1006440018.7 KBa49ce756cf8af0e6a20adc45666a272a1f1dc2091e07fa12b4fa5bc47af67e51
lib/kafka/consumer_group.rb100644005.03 KB8431e99b0094efb162a07c5e8006e93980814cf86789be114cae1434e472caac
lib/kafka/datadog.rb1006440010.2 KB259e3d9a5e190f5a5c41c9a0a92cd3fdb900340d5037fabf0b66ea5f296237ae
lib/kafka/fetch_operation.rb100644004.44 KB60f030eb41e9cf64e5f0ee4acb9f2e5ec740388e61a9b08040d011498dc63964
lib/kafka/fetched_batch.rb100644001 KB05cd1479516fc8af1e6bd9ad7abe8751f118a1abdcfb90fd3dd52f75951112f5
lib/kafka/fetched_message.rb10064400787 Bytes8d6bf0262c85f2a2848b043251a0ab74446af0fd3c44382656847cd5f47c9561
lib/kafka/fetcher.rb100644004.44 KB1f0f7bcae9a8a3145180ef8e568ae52c7400f38a5e15941d64a0d1cfe8b2b589
lib/kafka/gzip_codec.rb10064400512 Bytes8660c6816f814fb095d4dc3bbdadad21fd0a7e3bab8f758cb7f5391aaf202e29
lib/kafka/heartbeat.rb10064400321 Bytes2ace01bf588382693bd9616b13699496169fe5481780f7883be9ea411d81842e
lib/kafka/instrumenter.rb10064400850 Bytesfc479fe25b9b699657c0ef64aafd4304c06fa948106e54a40072112e791c365a
lib/kafka/lz4_codec.rb10064400364 Bytes2add56b48bffd89f23668297d3ac9145c9008a58ae9783e96bea247c717763dd
lib/kafka/message_buffer.rb100644001.91 KB2e437a5b60b2437ae2c7cc3e7850a918f88f2a861afdc09f84e9bd73a2a07102
lib/kafka/offset_manager.rb100644007.94 KB547c43ee1338ab27fb579788792ab45aea51b9a7eb0651305aac8a491b01269f
lib/kafka/partitioner.rb100644001.08 KB5c235bfc316a6e67576af91f05d8f83e7c810feabb9f8e0045fe93384f9832c7
lib/kafka/pending_message.rb10064400729 Bytes6d60ab93963216b40805946ac14af0f0f51635d9e3a484118a57d79872e03952
lib/kafka/pending_message_queue.rb10064400627 Bytes5d035894d99b60bca7a49ff0a611a348b34d2707668c8607612f17f3b7d33800
lib/kafka/produce_operation.rb100644006.26 KBdeb72eb9108cb0de754efea6a760cc2cd3ce184dce5f328a56f07fe2f842a739
lib/kafka/producer.rb1006440014.2 KBaca69f8276766cffe0d99c076834648f485d61ce9f1a1b1523e3c8110a9cf0b1
lib/kafka/protocol.rb100644005.99 KB0043d9cb404c45123202d44a3856de346cdff3ee0b4374d12e0d3294731d6047
lib/kafka/protocol/alter_configs_request.rb10064400990 Bytesc1c84ff6120f3e31fb6877e34f90f61df91fa6fbc265ecf1207db2b313e48803
lib/kafka/protocol/alter_configs_response.rb100644001.26 KB080fd9874ac3301494f0cf34d5bb6dce13dd13a5646605a6f8baf5ef05197baf
lib/kafka/protocol/api_versions_request.rb10064400269 Bytes83b74883674fa69e370ef8489b67595c1c634c27b48c9b0a407c8d94a0d4d889
lib/kafka/protocol/api_versions_response.rb100644001.1 KBcf843e1bf95d5ac0f1fa7c29c9c1637dd41ce71f9cd26f2ba62592563039ce80
lib/kafka/protocol/consumer_group_protocol.rb10064400423 Bytesef2b1da289f175c36c372ae5ca3dd969821b33681e3ae2e031f758c50fa211b4
lib/kafka/protocol/create_partitions_request.rb10064400959 Bytesb4ad1b80e8e2368db7f4ef08a99e519c1e0fd9965a2d5a055222bd2f48abf065
lib/kafka/protocol/create_partitions_response.rb10064400592 Bytes221c10a2089b49a15282f3cfd1384afa23e9a0bf447dbf3102053004d07bd66a
lib/kafka/protocol/create_topics_request.rb100644001.01 KB7b5a6a90701ce8386a7fc5954cbf40840f820ea2a2259c3cbd97131373ca06f2
lib/kafka/protocol/create_topics_response.rb10064400392 Bytesf464ebfc528f7708b6b15e0b35159b2b5b47cbe3a15935279408ca3ac1b57bbd
lib/kafka/protocol/decoder.rb100644002.53 KBbb746f5b00cf6ad365d1691fe3bfe0acc8b742755b3cdceb874ed0294934bce9
lib/kafka/protocol/delete_topics_request.rb10064400556 Bytes657e38ae006b410b04fd9eed5feec2ae834512952a344744cc5b09a2e64e6406
lib/kafka/protocol/delete_topics_response.rb10064400392 Bytesb010e6a742ec9d6fb61270adb21944a33a3a408ae497046f456fd8cb69be9f7d
lib/kafka/protocol/describe_configs_request.rb10064400629 Bytesc423e8478f3126c7cb7fd94f727e4b4a3aa5836ba200348b870f2150fcfcf5d9
lib/kafka/protocol/describe_configs_response.rb100644001.98 KBa3e008d31f903d4642655f87a7d4477ce28919a7cf1524443444a5f4386a9d49
lib/kafka/protocol/encoder.rb100644002.83 KB66926da1020ac6f2531e8f3f9b2b723a30758aef2fa4b6bc8ff33d9d3ff8763a
lib/kafka/protocol/fetch_request.rb100644001.59 KB90d135f13751f3bf5f22ca3e8724831541b98604ed7dd4e5afc7852a077cd422
lib/kafka/protocol/fetch_response.rb100644002.05 KBe942301e0ebdfd5a3fd72141dd156bff08533af05027460e0d89b2f44513fc26
lib/kafka/protocol/group_coordinator_request.rb10064400359 Bytesa36ba1751ca42f473c4462c31962fdcefb77b54398fc5a5311483bd3907407ce
lib/kafka/protocol/group_coordinator_response.rb10064400681 Bytes6c0faf47b28f2389394433ae3172ba9687fe48318cd87e6044b18814e106e65c
lib/kafka/protocol/heartbeat_request.rb10064400520 Bytes1939772b36c7cc443b7208877d6c329c3d7d2837c53cbb89a69fce89a00245b5
lib/kafka/protocol/heartbeat_response.rb10064400266 Bytesd487bb6ed93c059cfee98612d8f0393bd502bd3217e277882c68a5b5d98c2810
lib/kafka/protocol/join_group_request.rb100644001.01 KB913fc604414999cb0446e5d69c6d884518619a2560c856aef1df5446889b571d
lib/kafka/protocol/join_group_response.rb10064400858 Bytes75f5a869558a598664e04858877a9311006299dd1069124ac7885b09d9daaa77
lib/kafka/protocol/leave_group_request.rb10064400425 Bytese15192e20e4d3c005f51152cc26b68d008283db43525b6a0111a4c84ba9116de
lib/kafka/protocol/leave_group_response.rb10064400267 Bytes8a9887ed4d42dfbcc1306ea73b060a06e23d3b39f2ba4ac2eb66752426186a4f
lib/kafka/protocol/list_offset_request.rb100644001.11 KBeaecd35fba189f561720011fd01ba02ef3dc88d616e891995b59d9258bd5eded
lib/kafka/protocol/list_offset_response.rb100644001.97 KBf122d94de9d3f75e91bc0f94aef41a4ee592a411c29f1aec547c709bfea2702d
lib/kafka/protocol/member_assignment.rb10064400946 Bytesc13f289381f59f125323cb9f56cc03ced042603804e3246208c869941f141c30
lib/kafka/protocol/message.rb100644004.91 KBfd73f512ba61d6d062ecb86a6deb202c933526862668257fb2072fb75d644945
lib/kafka/protocol/message_set.rb100644001.29 KBf984e0f33970108eb3a371969017a77584a4479be8913c21d66eabb95d773758
lib/kafka/protocol/metadata_request.rb10064400513 Bytesfeeecb7461f6d7b1a45ea0732504673df90d1592131fb321c4c0e700bb38f975
lib/kafka/protocol/metadata_response.rb100644005.72 KBc027b37bf615080b8dd0b02d06d2243031e21b0eab345f161083af39cac8c19d
lib/kafka/protocol/offset_commit_request.rb100644001.16 KB555dd324e69d980d12bd96d4f8daba36ac98687683262e7eaa6df7c55b8fced7
lib/kafka/protocol/offset_commit_response.rb10064400527 Bytes21ea1be5cf683c1b73c9d8d121ac9dcfa5d1524028e8edecc672fd03c577451e
lib/kafka/protocol/offset_fetch_request.rb10064400647 Bytes0f0a7deecf3590fe8513021a9de6ab1f1a471e6fe47596ab67c89b6296100c5d
lib/kafka/protocol/offset_fetch_response.rb100644001.15 KBbb585e73abca33645495ade81958fabdef6162b71f1ca84ce9191fe6a8b736d9
lib/kafka/protocol/produce_request.rb100644002.34 KB7891c092e1231834d675c153a0b6d7a56a5440c42f66b76dcb010019c41ff83b
lib/kafka/protocol/produce_response.rb100644001.49 KBcd6fdce807563916b0996b7cb78f82086e5a93ee097612880f7d269df1a835d5
lib/kafka/protocol/request_message.rb10064400601 Bytes5c882647f314c7a8bde4a7cfbc15d10fe7e87e2d6eb615b562b384790c0d7d33
lib/kafka/protocol/sasl_handshake_request.rb10064400702 Bytes9b6f1c4c9b42bb9b93b244d660043b574c1e9c2a5323a89d0b4b4b36965aa92f
lib/kafka/protocol/sasl_handshake_response.rb10064400615 Bytes55f9e1ccfa589219bff1d18c419cf3472050af24e4d9ed2fa7a56323a5da3328
lib/kafka/protocol/sync_group_request.rb10064400794 Bytes3ab74d5c51f854f5f7bc7977243b021d2183b611b1c61e348b145d9c417880ca
lib/kafka/protocol/sync_group_response.rb10064400508 Bytes8b6d9f06cfd5cd933b1a8ff9392f3f5af88fefc1684fb5a56cd4d1757adc2cf2
lib/kafka/round_robin_assignment_strategy.rb100644001.38 KBa50b62cdbe02c8891b41a706c8fce50b423709419bc863c2d1a30ebe04ecba96
lib/kafka/sasl/gssapi.rb100644001.98 KB71874662f60a74f95ffc809e502f9f8ed39036d254c5567a0f7bc5af8fae76d8
lib/kafka/sasl/plain.rb10064400909 Bytes2e17a0275779406e24cd4771b8b9f96887384a43e92d891ace2c8e8feb2a6592
lib/kafka/sasl/scram.rb100644004.1 KB7c1e385649a6cfda4e532fb36f2a76ee9fa8fb4446d9181e24ad958479aff8e6
lib/kafka/sasl_authenticator.rb100644001.44 KBa767023ae3b4784ebe950812f6d93a9af9565f7effb88fb7e71328f6c0da0dd6
lib/kafka/snappy_codec.rb10064400431 Bytes0adf44ec29234168f650000fcef1df4772d1c1fa752cb1a29f41431d57aa246c
lib/kafka/socket_with_timeout.rb100644002.83 KBd9e43689b8c42ccb6693a048a2e0b357f071ce1f63a3fd62c49e90ccb887eaf7
lib/kafka/ssl_context.rb100644001.33 KB95e8b8add4de4842d1424ae265d080a7e44032c12f193a8d35da5ddfd6f0d5d1
lib/kafka/ssl_socket_with_timeout.rb100644006.17 KB75acdae005194bf7649b5c4a39eee71bbbb2acbe2232f04e80aee767fe7a6084
lib/kafka/statsd.rb100644009.01 KB9ccd4f87c14fe95a6080096a3a5cdb04b324442b07cd42baeb06d599a5ae7ac5
lib/kafka/version.rb1006440043 Bytescec73ecfafdc703729fc08c3e9d066a4303658f87da58c3e5cc7a2db0d62a0c0
lib/ruby-kafka.rb1006440073 Bytes824f3c16fb05879c1c499308503433e3d2758fcb86db251432eddb9ea4e29fb6
ruby-kafka.gemspec100644001.85 KB96d3aa04e39faa22d17cd656ee3572096a97e930292c87d192d7c5e75485cd4d