Skip to content

Commit

Permalink
[plugin-kafka] Use default partition and timestamp for sending events
Browse files Browse the repository at this point in the history
  • Loading branch information
valfirst committed Jun 20, 2024
1 parent 380e3e3 commit 744ff69
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ public void sendEvent(String value, String producerKey, String topic)
public void sendEventWithKey(String key, String value, String producerKey, String topic)
throws InterruptedException, ExecutionException, TimeoutException
{
ProducerRecord record = new ProducerRecord(topic, 0, 0L, key, value,
ProducerRecord<String, String> record = new ProducerRecord<>(topic, null, key, value,
testContext.remove(HEADERS_KEY));
kafkaTemplates.get(producerKey).send(record).get(WAIT_TIMEOUT_IN_MINUTES, TimeUnit.MINUTES);
}
Expand Down

0 comments on commit 744ff69

Please sign in to comment.