Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
h1alexbel committed May 8, 2023
1 parent 99a6ee4 commit 469d3df
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/java/io/github/eocqrs/kafka/Producer.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
import java.util.concurrent.Future;
import org.apache.kafka.clients.producer.RecordMetadata;
/**
* @todo #236:30m/DEV Producer send data without partition
* @todo #287:30m/DEV Producer send is not flexible enough
*/

/**
Expand Down
2 changes: 2 additions & 0 deletions src/main/java/io/github/eocqrs/kafka/producer/KfProducer.java
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,9 @@
import io.github.eocqrs.kafka.Data;
import io.github.eocqrs.kafka.Producer;
import io.github.eocqrs.kafka.ProducerSettings;

import java.util.concurrent.Future;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
Expand Down

0 comments on commit 469d3df

Please sign in to comment.