nomisRev / kotlin-kafka

Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.
https://nomisRev.github.io/kotlin-kafka/
Apache License 2.0
103 stars 10 forks source link

KafkaPublisher Class Missing from Latest Release Jar #186

Closed navneetpandey closed 5 months ago

navneetpandey commented 5 months ago

Hello,

I've been exploring the kotlin-kafka library and wanted to utilize the KafkaPublisher class as illustrated in the README examples. However, it appears that the entire publisher directory, including the KafkaPublisher class, is not present in the latest released jar file.

This discrepancy between the documentation and the library's content has led to a blocking issue in using the library as intended.

For instance, the README contains the following example:

...
KafkaPublisher(settings).use { publisher ->
  publisher.publishScope {
    (1..msgCount).forEach { index ->
      offer(ProducerRecord(topicName, Key(index), Message("msg: $index")))
    }
  }
}
... 

Upon inspecting the jar file, it seems that the publisher folder is absent, which suggests that KafkaPublisher and related classes cannot be found for import and use.

Could you please look into this and update the jar file to include all the necessary components as per the documentation? Alternatively, if the class has been relocated or restructured, an update to the README with the current usage would be greatly appreciated.

Thank you for your assistance and for providing the community with this valuable resource.

nomisRev commented 5 months ago

Hey @navneetpandey,

First of all thank you for your interest, and support of this library ☺️ 🥳

I have indeed not released this yet, I was hoping to have more time right after building this. I think we can do a 0.4.0 release whilst I continue the progress to 1.0 in Q3/4 this year. (Need to prepare for KotlinConf 🙈).

That should solve this issue, I will trigger it later today after office hours 😉

navneetpandey commented 5 months ago

Thank you for prompt response. Looking forward for 0.4.0. Good luck with KotlinConf, will join online :).

nomisRev commented 5 months ago

Thank you @navneetpandey! ☺️ 0.4.0 is released to MavenCentral, and should be available!