Skip to content

Commit

Permalink
Mosip 30687 on demand template extraction authentication error eventi…
Browse files Browse the repository at this point in the history
…ng (#1236)

* MOSIP-30687 changes done to  from websub to kafka

Signed-off-by: Neha Farheen <[email protected]>

* logger added

Signed-off-by: Neha Farheen <[email protected]>

---------

Signed-off-by: Neha Farheen <[email protected]>
Co-authored-by: Neha Farheen <[email protected]>
  • Loading branch information
Neha2365 and Neha Farheen authored Apr 4, 2024
1 parent b172d8f commit 1d71c66
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,9 @@
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.support.serializer.JsonSerializer;

import io.mosip.authentication.core.logger.IdaLogger;
import io.mosip.kernel.core.logger.spi.Logger;

/**
* The Class KafkaProducerConfig.
*
Expand All @@ -21,12 +24,14 @@

@Configuration
public class KafkaProducerConfig {
private static final Logger logger = IdaLogger.getLogger(KafkaProducerConfig.class);

@Value(value = "${mosip.ida.kafka.bootstrap.servers}")
private String bootstrapAddress;

@Bean
public ProducerFactory<String, Object> producerFactory() {
logger.info("Kafka bootstrap address" + bootstrapAddress);
Map<String, Object> configProps = new HashMap<>();
configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
Expand Down

0 comments on commit 1d71c66

Please sign in to comment.