build.gradle | 100644 | 0 | 0 | | | 4.42 KB | 98cafd6b55830c8a6effe9b72280e6b2d6cae59dabdbb5e6fc6527f86274beb5 |
.circleci/config.yml | 100644 | 0 | 0 | | | 1.12 KB | 9a7d0bbd0461313948eac7a6dec93fdefb07e3aa5f1a0281d38e2418c0775850 |
.github/dependabot.yml | 100644 | 0 | 0 | | | 505 Bytes | 5fcc1c700d94bbe75124156e87e52f4d800db4d0f9be398ac14638683f58d897 |
.gitignore | 100644 | 0 | 0 | | | 103 Bytes | 49811333e51b4c4e7e77040fb97e0da6c028701dc5837741e984c3d8a77832ff |
LICENSE.txt | 100644 | 0 | 0 | | | 1.01 KB | 000d5977886e3d8c6c863326d1a86cbffe32a9acf2847ea474501a8c7a5463fc |
README.md | 100644 | 0 | 0 | | | 3.95 KB | 87dc8457d80887cb7400244ab6367bbe0e1c6700eea65a5dd8c1949102912b17 |
classpath/avro-1.10.0.jar | 100644 | 0 | 0 | | | 575 KB | 51f91407456e1aeab0ac70008c13cfa84b7262c4bb16656f9897e57e2b1057f3 |
classpath/common-config-5.5.1.jar | 100644 | 0 | 0 | | | 23.4 KB | 2ac5c55d17598ab0dae42669874d52c585343ceeaf84bf9b4abb39d0d0e1a718 |
classpath/common-utils-5.5.1.jar | 100644 | 0 | 0 | | | 17.1 KB | 40a90ca4703fe1c07072d70217bf8949e6d22caf7ce26812168d28be743e29cf |
classpath/commons-compress-1.20.jar | 100644 | 0 | 0 | | | 618 KB | 0aeb625c948c697ea7b205156e112363b59ed5e2551212cd4e460bdb72c7c06e |
classpath/embulk-output-kafka-0.1.8.jar | 100644 | 0 | 0 | | | 25.6 KB | f06b8fbc5f61738581df0876dc135d13d9785888fa710d6f2618bbdd4505e6c4 |
classpath/jakarta.annotation-api-1.3.5.jar | 100644 | 0 | 0 | | | 24.5 KB | 85fb03fc054cdf4efca8efd9b6712bbb418e1ab98241c4539c8585bbc23e1b8a |
classpath/jakarta.inject-2.6.1.jar | 100644 | 0 | 0 | | | 17.7 KB | 5e88c123b3e41bca788b2683118867d9b6dec714247ea91c588aed46a36ee24f |
classpath/jakarta.ws.rs-api-2.1.6.jar | 100644 | 0 | 0 | | | 137 KB | 4cea299c846c8a6e6470cbfc2f7c391bc29b9caa2f9264ac1064ba91691f4adf |
classpath/javax.ws.rs-api-2.1.1.jar | 100644 | 0 | 0 | | | 124 KB | 2c309eb2c9455ffee9da8518c70a3b6d46be2a269b2e2a101c806a537efe79a4 |
classpath/jersey-common-2.30.jar | 100644 | 0 | 0 | | | 1.11 MB | 273cbee4d1997907a758aaaf1bd61b50de9bcaf2eb9e0aa4753c7828de111a1b |
classpath/kafka-avro-serializer-5.5.1.jar | 100644 | 0 | 0 | | | 25.1 KB | 387e29b397f4342ce7c0f999604cbf789e4b7d4deb946d75be2a2cb9710911cf |
classpath/kafka-clients-5.5.1-ccs.jar | 100644 | 0 | 0 | | | 3.2 MB | aa9496de855e0f6650610135c3771f88c68d08551989620b317375ca3d8dd9fb |
classpath/kafka-schema-registry-client-5.5.1.jar | 100644 | 0 | 0 | | | 105 KB | 7c8f1d98a864c18a8537089844915de167d64424d135bb98f69b65004579fb1c |
classpath/kafka-schema-serializer-5.5.1.jar | 100644 | 0 | 0 | | | 27.8 KB | 69c556fc741ace8fd84715bdadea9cbee9d4e4ca4b6f7663ef1ef6f47361b2b7 |
classpath/lz4-java-1.7.1.jar | 100644 | 0 | 0 | | | 635 KB | f1167a45d4b8002053670ef6991ca66d1bab9dcc03e4ef00183674d2f3fb9cac |
classpath/osgi-resource-locator-1.0.3.jar | 100644 | 0 | 0 | | | 19 KB | aab5d7849f7cfcda2cc7c541ba1bd365151d42276f151c825387245dfde3dd74 |
classpath/snappy-java-1.1.7.3.jar | 100644 | 0 | 0 | | | 1.93 MB | 7eea31c0a25d35cd092d8aec08bed04f22152409b58d63d43839074a9ab7ab97 |
classpath/swagger-annotations-1.6.0.jar | 100644 | 0 | 0 | | | 21.2 KB | 477baf349533bd3f31d31432c1c5c7abcd0bf852e8ab69e243469a944320e5e5 |
classpath/zstd-jni-1.4.4-7.jar | 100644 | 0 | 0 | | | 4.02 MB | 24ff5dbe06bb7ed31f4087df7d824d7b843880f3c953d608b4867f3ffd16ba7e |
config/checkstyle/checkstyle.xml | 100644 | 0 | 0 | | | 5.49 KB | cd105c56f95c1302888fa78f59a7fee4b8376564b7950a87ccd74014f286f48f |
config/checkstyle/default.xml | 100644 | 0 | 0 | | | 4.55 KB | d419e8196dd3265b86dd81dca6a85feaded2daf848a633b0bb4dfd1bafd89216 |
docker-compose.yml | 100644 | 0 | 0 | | | 1.12 KB | d6732cbcbe7a0d44cb0f0fbc6fe8ed07bb37472ef47283d483505781f128fa1d |
gradle/wrapper/gradle-wrapper.jar | 100644 | 0 | 0 | | | 53.4 KB | f4d953f31fbf6c38a8c330d19171c8ba6e0d1ff59d4d5c5c2d3ed821c9f3d5a3 |
gradle/wrapper/gradle-wrapper.properties | 100644 | 0 | 0 | | | 200 Bytes | 30f0361a38ee87c555e57c88c7658ffdf7065b16961348250c27670f39909b9e |
gradlew | 100755 | 0 | 0 | | | 5.17 KB | 8c4c04dd98db1f00d49456dd162418a39312c5cb13d6865d783deb483bd1ed22 |
gradlew.bat | 100644 | 0 | 0 | | | 2.21 KB | 0008d785920c9ff5cab17403e0270ccc7ceee8e169b6d67a82d96a5475fec5c9 |
lib/embulk/output/kafka.rb | 100644 | 0 | 0 | | | 147 Bytes | 399a1147d4934934ae65bad0801c2d196a044692404e35f67089001f75cfb31f |
src/main/java/org/embulk/output/kafka/AvroFormatColumnVisitor.java | 100644 | 0 | 0 | | | 8.3 KB | dc62009067491e0d117b4ad4b3b1b01d1ab8c7c4ca71b6a72660589c3bcff437 |
src/main/java/org/embulk/output/kafka/AvroFormatTransactionalPageOutput.java | 100644 | 0 | 0 | | | 557 Bytes | 1907d41f919888efad281c8c7f276e85bd5995722d1f397939a4e19837c95867 |
src/main/java/org/embulk/output/kafka/JsonFormatColumnVisitor.java | 100644 | 0 | 0 | | | 3.4 KB | b5ddff23a24d03f92b676f251def8e1433990164f834bf0ba01ec3b50dba30ad |
src/main/java/org/embulk/output/kafka/JsonFormatTransactionalPageOutput.java | 100644 | 0 | 0 | | | 568 Bytes | 36aa3cb91d785ee7b21738590375ae5c4b6f8b338017c3d16411c58eab6e52f3 |
src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java | 100644 | 0 | 0 | | | 757 Bytes | d1ee92b0e7e8f1d0926aaa08e8570fb482c0788f6b007acbab082dfb1bdb74f6 |
src/main/java/org/embulk/output/kafka/KafkaOutputColumnVisitor.java | 100644 | 0 | 0 | | | 2.92 KB | 42a33f7bcc590ff916cab534e405b83005d66769830e32c011b9e178240163ea |
src/main/java/org/embulk/output/kafka/KafkaOutputPlugin.java | 100644 | 0 | 0 | | | 9.73 KB | c4f06aa988234be2f07fe6f842521c16f1f6245bf6d4b3bed3888bae10f7cd75 |
src/main/java/org/embulk/output/kafka/KafkaTransactionalPageOutput.java | 100644 | 0 | 0 | | | 3.29 KB | 5337414a52c552563960382194e5865954647c68282b18772ef8b02d82f75fb3 |
src/main/java/org/embulk/output/kafka/RecordProducerFactory.java | 100644 | 0 | 0 | | | 4.5 KB | 4d6d191d0d9603231c28b34a09dd00411690f2e08ca8d244a59004d9e7cf97b3 |
src/test/java/org/embulk/output/kafka/TestKafkaOutputPlugin.java | 100644 | 0 | 0 | | | 17.8 KB | 00290281a51ef68840fef456eea7a23643a1f0cddf32fe664fb55b5539665c86 |
src/test/resources/SimpleRecord.avsc | 100644 | 0 | 0 | | | 195 Bytes | fc6614364499b5761a8eea6858466892051fd8d399c049277a041ce5292cab66 |
src/test/resources/config_complex.yml | 100644 | 0 | 0 | | | 170 Bytes | 87cf1a5729edcb0c43e8e1d66d6a1ce75b04a38ceb624ce8687cce20b8c2bb6a |
src/test/resources/config_complex_avro.yml | 100644 | 0 | 0 | | | 719 Bytes | b95a7e9aa50041c903ab7917536ad3aef2ada7a8e4ed80c771b30f5a176c7b60 |
src/test/resources/config_simple.yml | 100644 | 0 | 0 | | | 85 Bytes | 92c510135c5ec6fe0abf2443aedd5e536b797b684b8016ce51521be66d996bf4 |
src/test/resources/config_simple_avro.yml | 100644 | 0 | 0 | | | 337 Bytes | 9d294757adbf7b984b19a14e5cbfd6b0abbc8b34d7683c3a1a32f4c0323680c4 |
src/test/resources/config_simple_avro_avsc_file.yml | 100644 | 0 | 0 | | | 213 Bytes | a21be264781bf148296899628ad76dab9039ee682d113f4f470f2146ebda01a0 |
src/test/resources/config_with_column_for_deletion.yml | 100644 | 0 | 0 | | | 136 Bytes | b79d9853739b1912f17b859bee97e98b9105c3cb56f35e78d9d545fe6d5a9db7 |
src/test/resources/config_with_column_for_deletion_avro.yml | 100644 | 0 | 0 | | | 414 Bytes | 18f6b28a414d72958b94a740862053411c5d9e314db3a92ec1992b6e38940ff0 |
src/test/resources/config_with_key_column.yml | 100644 | 0 | 0 | | | 105 Bytes | 835e88f99bd7313d74041165bc46b6dee4b12f149c7fd36c5183339443dd39d4 |
src/test/resources/config_with_partition_column.yml | 100644 | 0 | 0 | | | 117 Bytes | 69dfc5a187bee2539981fe8ca9a77a92435b64eb1e33ebd9e3a577f0fb2550bb |
src/test/resources/in1.csv | 100644 | 0 | 0 | | | 89 Bytes | fb5e34cd40e43a2ee1d439716ec3a1d772e05a58afd5ca6171d54bff604f8bc8 |
src/test/resources/in_complex.csv | 100644 | 0 | 0 | | | 405 Bytes | fe29ba3c740bbe9993f3ace75c1ea7634ef252a0dfa99f0c84d190ec338acd95 |
src/test/resources/in_with_deletion.csv | 100644 | 0 | 0 | | | 128 Bytes | 83c313569454a0291c239a38e6b737dae5790b9dbf4270e5e91e6f7c0a08709a |