embulk-input-kafka-0.1.0

https://rubygems.org

embulk-input-kafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

id: 1342107

number: 0.1.0

platform: ruby

spec_sha256: 6590af52a2f7a9f54f5d2cac83c45018db9d31f2e1e0401893098bc6c16fd9b7

sha256: bc2301021ec2721019733c9166022f0d3354278004ea37dd53cb8a6d04bec4e7

created_at: 2024-05-13 08:34:17 UTC

updated_at: 2024-06-13 23:36:01 UTC

position: 1

version_data_entries_count: 46

uploaded_at: 2020-08-24 00:11:51 UTC

indexed: true

has_extensions:

extensions:

Gem size: 12.1 MB

Version Data Entries

Total: 46

Unpacked size: 12.8 MB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.circleci/config.yml100644001.12 KB9a7d0bbd0461313948eac7a6dec93fdefb07e3aa5f1a0281d38e2418c0775850
.gitignore10064400103 Bytes49811333e51b4c4e7e77040fb97e0da6c028701dc5837741e984c3d8a77832ff
LICENSE.txt100644001.01 KB000d5977886e3d8c6c863326d1a86cbffe32a9acf2847ea474501a8c7a5463fc
README.md100644001.99 KBd2e3067150437607734fee1a2a0198868e8ffacc889515d914554d9204322809
build.gradle100644005.02 KBa38b5a62152e1375e7e7d7e23be1b5ddf5caec28f5e2655b4aee2c5aaeb7ba66
classpath/avro-1.9.2.jar10064400574 KB9d8f65504604b5fcdffb96793a9a32ca7b10bc0a469425d1d1fe4aa490c31c02
classpath/common-config-5.5.1.jar1006440023.4 KB2ac5c55d17598ab0dae42669874d52c585343ceeaf84bf9b4abb39d0d0e1a718
classpath/common-utils-5.5.1.jar1006440017.1 KB40a90ca4703fe1c07072d70217bf8949e6d22caf7ce26812168d28be743e29cf
classpath/commons-compress-1.19.jar10064400601 KBff2d59fad74e867630fbc7daab14c432654712ac624dbee468d220677b124dd5
classpath/embulk-input-kafka-0.1.0.jar1006440031.4 KBc9348461758b24d791f7916c37321ce27c79052865e272cba08c47bbdc433a96
classpath/jackson-datatype-jsr310-2.6.7.jar1006440077 KB98dcc709c87942abfcd1b4ea0f46bad16e765602ace2da3efe97a00025ebe782
classpath/jakarta.annotation-api-1.3.5.jar1006440024.5 KB85fb03fc054cdf4efca8efd9b6712bbb418e1ab98241c4539c8585bbc23e1b8a
classpath/jakarta.inject-2.6.1.jar1006440017.7 KB5e88c123b3e41bca788b2683118867d9b6dec714247ea91c588aed46a36ee24f
classpath/jakarta.ws.rs-api-2.1.6.jar10064400137 KB4cea299c846c8a6e6470cbfc2f7c391bc29b9caa2f9264ac1064ba91691f4adf
classpath/javax.ws.rs-api-2.1.1.jar10064400124 KB2c309eb2c9455ffee9da8518c70a3b6d46be2a269b2e2a101c806a537efe79a4
classpath/jersey-common-2.30.jar100644001.11 MB273cbee4d1997907a758aaaf1bd61b50de9bcaf2eb9e0aa4753c7828de111a1b
classpath/kafka-avro-serializer-5.5.1.jar1006440025.1 KB387e29b397f4342ce7c0f999604cbf789e4b7d4deb946d75be2a2cb9710911cf
classpath/kafka-clients-5.5.1-ccs.jar100644003.2 MBaa9496de855e0f6650610135c3771f88c68d08551989620b317375ca3d8dd9fb
classpath/kafka-schema-registry-client-5.5.1.jar10064400105 KB7c8f1d98a864c18a8537089844915de167d64424d135bb98f69b65004579fb1c
classpath/kafka-schema-serializer-5.5.1.jar1006440027.8 KB69c556fc741ace8fd84715bdadea9cbee9d4e4ca4b6f7663ef1ef6f47361b2b7
classpath/lz4-java-1.7.1.jar10064400635 KBf1167a45d4b8002053670ef6991ca66d1bab9dcc03e4ef00183674d2f3fb9cac
classpath/osgi-resource-locator-1.0.3.jar1006440019 KBaab5d7849f7cfcda2cc7c541ba1bd365151d42276f151c825387245dfde3dd74
classpath/snappy-java-1.1.7.3.jar100644001.93 MB7eea31c0a25d35cd092d8aec08bed04f22152409b58d63d43839074a9ab7ab97
classpath/swagger-annotations-1.6.0.jar1006440021.2 KB477baf349533bd3f31d31432c1c5c7abcd0bf852e8ab69e243469a944320e5e5
classpath/zstd-jni-1.4.4-7.jar100644004.02 MB24ff5dbe06bb7ed31f4087df7d824d7b843880f3c953d608b4867f3ffd16ba7e
config/checkstyle/checkstyle.xml100644005.49 KBcd105c56f95c1302888fa78f59a7fee4b8376564b7950a87ccd74014f286f48f
config/checkstyle/default.xml100644004.55 KBd419e8196dd3265b86dd81dca6a85feaded2daf848a633b0bb4dfd1bafd89216
gradle/wrapper/gradle-wrapper.jar1006440053.4 KBf4d953f31fbf6c38a8c330d19171c8ba6e0d1ff59d4d5c5c2d3ed821c9f3d5a3
gradle/wrapper/gradle-wrapper.properties10064400203 Bytes90fb26b3f39bb87a36980ccf5660cc3f08f4c77c1dee14aa3609732944e35c2b
gradlew100755005.17 KB8c4c04dd98db1f00d49456dd162418a39312c5cb13d6865d783deb483bd1ed22
gradlew.bat100644002.21 KB0008d785920c9ff5cab17403e0270ccc7ceee8e169b6d67a82d96a5475fec5c9
lib/embulk/input/kafka.rb10064400144 Bytes05919545e53aa947ed699fb495eb331455b5b760ad8315b02de7b10ecd37f1b7
src/main/java/org/embulk/input/kafka/AbstractKafkaInputColumnVisitor.java100644004.1 KB6789e90b771e49372634c282b8303ae9c873984d7e225c3fcfe3b195364df2ae
src/main/java/org/embulk/input/kafka/AvroFormatColumnVisitor.java100644005.8 KBc53d81cb7451f6b987e3219ec8e0ee52807b71144ba74485ac215abfe5b441f9
src/main/java/org/embulk/input/kafka/JsonFormatColumnVisitor.java100644004.28 KB20ae73c8a40cf5db66c0e757a223d84a3cc55807b8ed7d6af9380336d3f74208
src/main/java/org/embulk/input/kafka/KafkaInputPlugin.java1006440016.3 KB5c48698ab118d52f7f260e97addb3425a00f5a4fdb18cfd63d88a5506d73d859
src/main/java/org/embulk/input/kafka/KafkaJsonDeserializer.java100644001.13 KBec80bc135aa8fd7ef376a152c5f10aa356cc266104dc89d774e49c53b769105c
src/test/avro/ComplexRecordAvro.avsc10064400729 Bytes93a103236940f7726b1e6ef351152ead6e7bac07b5ec5bb7ad44875644fa3275
src/test/avro/SimpleRecordAvro.avsc10064400241 Bytesf5d44df180341b5d7f36145ea5fbcd146147f82ff95a177a98a5e5a88f220a8b
src/test/java/org/embulk/input/kafka/ComplexRecord.java100644001.44 KBf1c3ae3d6ba350774b7bb2c5dfdc3c3b6a9d58201cbe78f184ef965f34db88a9
src/test/java/org/embulk/input/kafka/SimpleRecord.java10064400752 Bytes2dbd58f4ebdbe314c079583e61602f436f917d56b2caeeebebb20f9e5c84751e
src/test/java/org/embulk/input/kafka/TestKafkaInputPlugin.java1006440014.4 KBeea51d3e06bff5075e3ff3af214058b64ad0920e83f949452d162f30f9c71f99
src/test/resources/config_complex.yml10064400421 Bytes925e35e848f9eb991bb708589621bb74d338bdd71659333d19bbb976f64cf1e1
src/test/resources/config_complex_avro.yml10064400456 Bytes7d0e650add790a3b8814b0569b6d7cff9ee6e7b077cb128024bfff845573b1c9
src/test/resources/config_simple.yml10064400231 Bytesb481109a8e77c1b12c86d81289284cedc28cd54cf65c27b2e511810eb4621bf1
src/test/resources/config_simple_avro.yml10064400301 Bytes661840cfd4e3ad105e22ee115d53a6f2b459b0fd846a5ec440fb657151ae5160