Class HvlLogProducerConfigurableLogProviderKafkaConsumer
java.lang.Object
tr.com.havelsan.javarch.log.producer.configurablelog.provider.consumer.HvlLogProducerConfigurableLogProviderKafkaConsumer
Log producer configurable log provider kafka consumer.
-
Constructor Summary
ConstructorDescriptionHvlLogProducerConfigurableLogProviderKafkaConsumer
(HvlLogProducerConfigurableLogProviderCacheProvider cacheProvider) Instantiates a new HvlLogProducerConfigurableLogProviderKafkaConsumer. -
Method Summary
Modifier and TypeMethodDescriptionvoid
updateCache
(@javax.validation.constraints.NotNull byte[] settingOperationInfoEventByteArray) Updates cache.
-
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 @javax.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
-