stillya
/ jooq-conventions.gradle.kts
Created
November 19, 2022 20:43
It's example of configuration convention plugin for jOOQ+TC+Gradle+Flyway. V2
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import nu.studer.gradle.jooq.JooqEdition | |
| import org.jooq.meta.jaxb.ForcedType | |
| import nu.studer.gradle.jooq.JooqGenerate | |
| import org.flywaydb.gradle.task.FlywayMigrateTask | |
| import org.testcontainers.containers.PostgreSQLContainer | |
| plugins { | |
| id("java") | |
| id("org.flywaydb.flyway") | |
| id("nu.studer.jooq") |
stillya
/ testcontainer-conventions.gradle.kts
Created
July 13, 2022 13:58
It's example of configuration convention plugin for jOOQ+TC+Gradle+Flyway
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // ====================== IT'S PLUGIN ITSELF ====================== | |
| import org.testcontainers.containers.PostgreSQLContainer | |
| import org.testcontainers.utility.ResourceReaper | |
| plugins { | |
| id("java") | |
| id("something.kotlin-conventions") | |
| } |
stillya
/ kafka-metadata-bug.java
Last active
November 22, 2021 11:09
Async fire and forget sending message doesn't works correctly, it's block on waiting for metadata request, i guess. P.S. It's not actually bug, maybe this feature will be introduce in the future releases, look at KIP-286.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.stilya.kafka; | |
| import java.util.Properties; | |
| import org.apache.kafka.clients.producer.Callback; | |
| import org.apache.kafka.clients.producer.KafkaProducer; | |
| import org.apache.kafka.clients.producer.Producer; | |
| import org.apache.kafka.clients.producer.ProducerRecord; | |
| import org.apache.kafka.clients.producer.RecordMetadata; | |
| public class Main { |