Package tr.com.havelsan.javarch.log.producer.configurablelog.provider.consumer

Class HvlLogProducerConfigurableLogProviderKafkaConsumer

java.lang.Object

tr.com.havelsan.javarch.log.producer.configurablelog.provider.consumer.HvlLogProducerConfigurableLogProviderKafkaConsumer

@Component
public class HvlLogProducerConfigurableLogProviderKafkaConsumer
extends Object

Log producer configurable log provider kafka consumer.

Constructor Summary

Constructors

Constructor	Description
HvlLogProducerConfigurableLogProviderKafkaConsumer(HvlLogProducerConfigurableLogProviderCacheProvider cacheProvider)	Instantiates a new HvlLogProducerConfigurableLogProviderKafkaConsumer.

Method Summary

Modifier and Type	Method	Description
void	updateCache(@jakarta.validation.constraints.NotNull byte[] settingOperationInfoEventByteArray)	Updates cache.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

HvlLogProducerConfigurableLogProviderKafkaConsumer

public HvlLogProducerConfigurableLogProviderKafkaConsumer(HvlLogProducerConfigurableLogProviderCacheProvider cacheProvider)

Instantiates a new HvlLogProducerConfigurableLogProviderKafkaConsumer.

Parameters:

cacheProvider - the cache provider

Method Details

updateCache

@KafkaListener(topics="${hvl.logger.producer.configurable-log.setting-event-topic-name:javalt-system-setting-operation}",
               properties="value.deserializer:org.apache.kafka.common.serialization.ByteArrayDeserializer")
public void updateCache(@NotNull
 @jakarta.validation.constraints.NotNull byte[] settingOperationInfoEventByteArray)
                 throws IOException

Updates cache.

We used byte[] param to prevent system setting module dependency. We are getting HvlSettingOperationInfoEventModel as byte array.

Parameters:

settingOperationInfoEventByteArray - the setting operation info event byte array

Throws:

IOException - the io exception

See Also:

• HvlLogProducerConfigurableLogProviderKafkaConsumer.HvlLogProducerProviderCacheSettingEventModel
• ByteArrayDeserializer