.gitignore | 100644 | 0 | 0 | | | 103 Bytes | 49811333e51b4c4e7e77040fb97e0da6c028701dc5837741e984c3d8a77832ff |
LICENSE.txt | 100644 | 0 | 0 | | | 1.01 KB | 000d5977886e3d8c6c863326d1a86cbffe32a9acf2847ea474501a8c7a5463fc |
README.md | 100644 | 0 | 0 | | | 3.48 KB | 6236d5c335e8981402e38931e178453b519974f33666c66a98aa7b9eaa14adda |
build.gradle | 100644 | 0 | 0 | | | 3.26 KB | 9197f2aedafcf16b29050279084cade5a7f341a4a0dc3f160d6c6510b8740c61 |
classpath/audience-annotations-0.5.0.jar | 100644 | 0 | 0 | | | 20 KB | c82631f06c75d46bf6524d95f0d6c2e3aef1b3eb4a7b584ca296624ef0d474be |
classpath/avro-1.9.0.jar | 100644 | 0 | 0 | | | 553 KB | d86f8757e5b50ea981a386630dc9fe9e3eb857c84b75c37aeebfab5052aefd6b |
classpath/common-config-5.3.0.jar | 100644 | 0 | 0 | | | 23.1 KB | 812281b65a7abe3caac7e57256f5917b009dc690418c42230e007e361d735a30 |
classpath/common-utils-5.3.0.jar | 100644 | 0 | 0 | | | 20.4 KB | c4272e4121e1878b426d0739b8343691402da6141c73e932b686192709ebe1c9 |
classpath/commons-compress-1.18.jar | 100644 | 0 | 0 | | | 578 KB | 5f2df1e467825e4cac5996d44890c4201c000b43c0b23cffc0782d28a0beb9b0 |
classpath/embulk-output-kafka-0.1.6.jar | 100644 | 0 | 0 | | | 25.5 KB | f5244444c959e9b9d503e6e840f9b44af6cda342e3bf393f5239b6ba3fb01630 |
classpath/jackson-annotations-2.9.0.jar | 100644 | 0 | 0 | | | 65 KB | 45d32ac61ef8a744b464c54c2b3414be571016dd46bfc2bec226761cf7ae457a |
classpath/jackson-core-2.9.9.jar | 100644 | 0 | 0 | | | 318 KB | 3083079be6088db2ed0a0c6ff92204e0aa48fa1de9db5b59c468f35acf882c2c |
classpath/jackson-databind-2.9.9.jar | 100644 | 0 | 0 | | | 1.29 MB | 5cbbf429d9e32e3881f0a1438a1f666912219327e9e68b5dcaef6d8e5c5f6b28 |
classpath/jline-0.9.94.jar | 100644 | 0 | 0 | | | 85.3 KB | d8df0ffb12d87ca876271cda4d59b3feb94123882c1be1763b7faf2e0a0b0cbb |
classpath/jsr305-3.0.2.jar | 100644 | 0 | 0 | | | 19.5 KB | 766ad2a0783f2687962c8ad74ceecc38a28b9f72a2d085ee438b7813e928d0c7 |
classpath/kafka-avro-serializer-5.3.0.jar | 100644 | 0 | 0 | | | 34.8 KB | 9262a57939c3ae9130e5d141dc7d51b3369480b6bc9d363adf7223180cd1d22e |
classpath/kafka-clients-5.3.0-ccs.jar | 100644 | 0 | 0 | | | 2.61 MB | b55e216c54856c23ca79a6f5f2cb03065e4ab8ed77a066ee851d3f07d99b8950 |
classpath/kafka-schema-registry-client-5.3.0.jar | 100644 | 0 | 0 | | | 63.7 KB | 36864b985409adb24aae2d4999dc0455c1da9996f57877ee5e9e62d2af583362 |
classpath/lz4-java-1.6.0.jar | 100644 | 0 | 0 | | | 625 KB | d229545aa2b1d5203c876614bdbcffcacc303697f4f8f26f764e1d6c1ed2e416 |
classpath/netty-3.10.6.Final.jar | 100644 | 0 | 0 | | | 1.23 MB | 8768a50fbe3d93a88d8e6000ea5d68e30f50dc915b3764c3c5870f70c4fb3b49 |
classpath/slf4j-api-1.7.26.jar | 100644 | 0 | 0 | | | 40.2 KB | 6d9e5b86cfd1dd44c676899285b5bb4fa0d371cf583e8164f9c8a0366553242b |
classpath/snappy-java-1.1.7.3.jar | 100644 | 0 | 0 | | | 1.93 MB | 7eea31c0a25d35cd092d8aec08bed04f22152409b58d63d43839074a9ab7ab97 |
classpath/spotbugs-annotations-3.1.9.jar | 100644 | 0 | 0 | | | 14.8 KB | 68c7c46b4299e94837e236ae742f399901a950fe910fe3ca710026753b5dd2e1 |
classpath/zkclient-0.10.jar | 100644 | 0 | 0 | | | 73 KB | 26e988b8bba838c724fd8350b331ee8b5ffc59c3a9c074df115c4c3a6c843878 |
classpath/zookeeper-3.4.14.jar | 100644 | 0 | 0 | | | 890 KB | 23ef2bf90c8ca233f68bf3c24ab69947fc7b38e8c8b9327f5c2fd9140ae7aecf |
classpath/zstd-jni-1.4.0-1.jar | 100644 | 0 | 0 | | | 3.8 MB | 0d45847c7a1fc59c24ee71d942cc1faea6a78ce7a88bf65838358bda2a316567 |
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 | b97e9bcc6374016adbe93b9e5fe88e25f9257a816b76f91ad189576ddabb4c4a |
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.22 KB | 397c5ca24d9841c6d2c7d903a4b7abd271c9f2a66fb493e189aa0ca0d642f642 |
src/main/java/org/embulk/output/kafka/JsonFormatColumnVisitor.java | 100644 | 0 | 0 | | | 3.27 KB | 09e56de0fc7060743644cc1e81b5bc7efcc0cdaad2fc57cd7ee3aca3376457ea |
src/main/java/org/embulk/output/kafka/KafkaJsonSerializer.java | 100644 | 0 | 0 | | | 693 Bytes | 1dc89dfac803a17565ab94af2fa79a0926c1a21bdaed796e3ef416650a35ca31 |
src/main/java/org/embulk/output/kafka/KafkaOutputColumnVisitor.java | 100644 | 0 | 0 | | | 2.36 KB | 6b81217d9a3ec1d397cf0bb8eb986f16176e5999a83b4da7625b6b185ab278ac |
src/main/java/org/embulk/output/kafka/KafkaOutputPlugin.java | 100644 | 0 | 0 | | | 12.4 KB | cc21a79f18112ba4c6d56500f2a8396c28beac7ac092202b4b647d44bcf14af0 |
src/main/java/org/embulk/output/kafka/RecordProducerFactory.java | 100644 | 0 | 0 | | | 4.49 KB | 61f9b28f9360dbb084ad7ad1b55ae704bb6ce1033f0f047b9e1e8e90ab5cb229 |
src/test/java/org/embulk/output/kafka/TestKafkaOutputPlugin.java | 100644 | 0 | 0 | | | 73 Bytes | 78ac22f9c2557f76d38a9b57bc7a16d81bfcce14cd90475c56e61a061d017762 |
src/test/resources/SimpleRecord.avsc | 100644 | 0 | 0 | | | 195 Bytes | fc6614364499b5761a8eea6858466892051fd8d399c049277a041ce5292cab66 |
src/test/resources/config_complex.yml | 100644 | 0 | 0 | | | 629 Bytes | ece530cf5c97a5828a12eee946249b367263bd86bc9f1dd4d14e715931d1002b |
src/test/resources/config_complex_avro.yml | 100644 | 0 | 0 | | | 1.18 KB | c5c749ef7dd7e6d7584699f678b372c2309e08acb488623f851949501403ed67 |
src/test/resources/config_simple.yml | 100644 | 0 | 0 | | | 443 Bytes | 052e4b6a012f4f2b51f18383f1b2158dd8b5c752a6f5433341b9a4387b0039eb |
src/test/resources/config_simple_avro.yml | 100644 | 0 | 0 | | | 711 Bytes | 72bce37675a30fe6e5f1a452cbd0ed169184844d32cf5e19815cfebf9327eef1 |
src/test/resources/config_simple_avro_avsc_file.yml | 100644 | 0 | 0 | | | 573 Bytes | 9be3a10ec4441e794aeada700bf514be2213a31d70b4c6efda2ff61eda289834 |
src/test/resources/config_with_key_column.yml | 100644 | 0 | 0 | | | 465 Bytes | eaa28ec42ae3d05c5a0cd643b851b09986365c30c80251f97f60b1f4066e062e |
src/test/resources/in1.csv | 100644 | 0 | 0 | | | 52 Bytes | 25dc6c85f1232307fc2bd3d2046b233710ee823febab6becdf083cdd2b16282b |
src/test/resources/in_complex.csv | 100644 | 0 | 0 | | | 285 Bytes | b679b1947a996522ef39d008225074985b5e5b1d13b0acab9c02841ef24e1668 |