Skip to content

Commit

Permalink
[MODAUD-195]. Rename restricted arg name
Browse files Browse the repository at this point in the history
  • Loading branch information
BKadirkhodjaev committed Nov 4, 2024
1 parent 9704242 commit 0c64f7d
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -72,9 +72,9 @@ void shouldProcessEvent() {
saveFuture.onComplete(ar -> Assertions.assertTrue(ar.succeeded()));
}

private KafkaConsumerRecord<String, String> buildKafkaConsumerRecord(InvoiceLineAuditEvent record) {
String topic = KafkaTopicNameHelper.formatTopicName(KAFKA_ENV, getDefaultNameSpace(), TENANT_ID, record.getAction().toString());
ConsumerRecord<String, String> consumerRecord = buildConsumerRecord(topic, record);
private KafkaConsumerRecord<String, String> buildKafkaConsumerRecord(InvoiceLineAuditEvent kafkaConsumerRecord) {
String topic = KafkaTopicNameHelper.formatTopicName(KAFKA_ENV, getDefaultNameSpace(), TENANT_ID, kafkaConsumerRecord.getAction().toString());
ConsumerRecord<String, String> consumerRecord = buildConsumerRecord(topic, kafkaConsumerRecord);
return new KafkaConsumerRecordImpl<>(consumerRecord);
}

Expand Down

0 comments on commit 0c64f7d

Please sign in to comment.