SCRUM-3479: Added event consumer to create audit logs for metadata service

This commit is contained in:
Vishal Raut 2026-02-04 17:38:27 +05:30
parent 7698425749
commit e0cfded15a
9 changed files with 43 additions and 5 deletions

View File

@ -26,7 +26,14 @@
-->
# [1.1.0] - 2026-01-20
# [1.4.0] - 2026-02-04
### [SCRUM-3479](https://itserr-wp2.atlassian.net/browse/SCRUM-3479)
### Added
- added event consumer to create audit logs for metadata service
- added unit and integration tests
### [SCRUM-3239](https://itserr-wp2.atlassian.net/browse/SCRUM-3239)

View File

@ -40,6 +40,9 @@ audit_bs_messaging_workspace_bs_event_stream_consumer_dlq_name: itserr-stream-wo
audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled: true
audit_bs_messaging_favourite_user_bs_event_stream_name: itserr-stream-favourite-user-event
audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name: itserr-stream-favourite-user-event-dlq
audit_bs_messaging_metadata_bs_event_stream_consumer_enabled: true
audit_bs_messaging_metadata_bs_event_stream_name: itserr-stream-metadata-event
audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name: itserr-stream-metadata-event-dlq
#diagnostics
audit_bs_diagnostics_publish_message_enabled: true

View File

@ -47,7 +47,9 @@ audit_bs_messaging_workspace_bs_event_stream_consumer_dlq_name: itserr-stream-wo
audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled: true
audit_bs_messaging_favourite_user_bs_event_stream_name: itserr-stream-favourite-user-event
audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name: itserr-stream-favourite-user-event-dlq
audit_bs_messaging_metadata_bs_event_stream_consumer_enabled: true
audit_bs_messaging_metadata_bs_event_stream_name: itserr-stream-metadata-event
audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name: itserr-stream-metadata-event-dlq
audit_bs_log_base_folder: logs

View File

@ -40,6 +40,9 @@ audit_bs_messaging_workspace_bs_event_stream_consumer_dlq_name: itserr-stream-wo
audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled: true
audit_bs_messaging_favourite_user_bs_event_stream_name: itserr-stream-favourite-user-event
audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name: itserr-stream-favourite-user-event-dlq
audit_bs_messaging_metadata_bs_event_stream_consumer_enabled: true
audit_bs_messaging_metadata_bs_event_stream_name: itserr-stream-metadata-event
audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name: itserr-stream-metadata-event-dlq
#diagnostics
audit_bs_diagnostics_publish_message_enabled: true

View File

@ -40,6 +40,9 @@ audit_bs_messaging_workspace_bs_event_stream_consumer_dlq_name: itserr-stream-wo
audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled: true
audit_bs_messaging_favourite_user_bs_event_stream_name: itserr-stream-favourite-user-event
audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name: itserr-stream-favourite-user-event-dlq
audit_bs_messaging_metadata_bs_event_stream_consumer_enabled: true
audit_bs_messaging_metadata_bs_event_stream_name: itserr-stream-metadata-event
audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name: itserr-stream-metadata-event-dlq
#diagnostics
audit_bs_diagnostics_publish_message_enabled: true

View File

@ -153,6 +153,12 @@ messaging:
enabled: ${audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled}
dlq:
name: ${audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name}
- name: ${audit_bs_messaging_metadata_bs_event_stream_name}
consumer:
<<: *consumer_defaults
enabled: ${audit_bs_messaging_metadata_bs_event_stream_consumer_enabled}
dlq:
name: ${audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name}
# Logging

View File

@ -54,7 +54,7 @@ import static org.mockito.Mockito.verify;
*/
@CoreMessagingServer(messagingPropertiesPrefix = "audit_bs", producerStream = "",
consumerStreams = {"catalog-bs", "discussion-bs", "event-bs", "institutional-page-bs",
"news-bs", "user-profile-bs", "workspace-bs", "favourite-user-bs"})
"news-bs", "user-profile-bs", "workspace-bs", "favourite-user-bs", "metadata-bs"})
@Slf4j
public class MessagingEventConsumerIT extends AbstractMessagingIT {

View File

@ -4,7 +4,7 @@ public class TestConstants {
// This should match the values provided on the consumerStreams for CoreMessagingServer annotation
public static final String[] SUPPORTED_CONSUMER_STREAMS = new String[]{
"catalog-bs", "discussion-bs", "event-bs", "institutional-page-bs", "news-bs", "user-profile-bs",
"workspace-bs", "favourite-user-bs"};
"workspace-bs", "favourite-user-bs", "metadata-bs"};
public static final String PRODUCER_NAME_ERROR_FORMAT = "test-producer-error-%s-%s";
public static final int MESSAGE_RETRY_COUNT = 2;

View File

@ -25,16 +25,30 @@ audit_bs_messaging_auth_client_secret: ignored
audit_bs_messaging_catalog_bs_event_stream_consumer_enabled: true
audit_bs_messaging_catalog_bs_event_stream_name: ignored
audit_bs_messaging_catalog_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_discussion_bs_event_stream_consumer_enabled: true
audit_bs_messaging_discussion_bs_event_stream_name: ignored
audit_bs_messaging_discussion_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_event_bs_event_stream_consumer_enabled: true
audit_bs_messaging_event_bs_event_stream_name: ignored
audit_bs_messaging_event_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_institutional_page_bs_event_stream_consumer_enabled: true
audit_bs_messaging_institutional_page_bs_event_stream_name: ignored
audit_bs_messaging_institutional_page_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_news_bs_event_stream_consumer_enabled: true
audit_bs_messaging_news_bs_event_stream_name: ignored
audit_bs_messaging_news_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_user_profile_bs_event_stream_consumer_enabled: true
audit_bs_messaging_user_profile_bs_event_stream_name: ignored
audit_bs_messaging_user_profile_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_workspace_bs_event_stream_consumer_enabled: true
audit_bs_messaging_workspace_bs_event_stream_name: ignored
audit_bs_messaging_workspace_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_favourite_user_bs_event_stream_consumer_enabled: true
audit_bs_messaging_favourite_user_bs_event_stream_name: ignored
audit_bs_messaging_favourite_user_bs_event_stream_consumer_dlq_name: ignored
audit_bs_messaging_metadata_bs_event_stream_consumer_enabled: true
audit_bs_messaging_metadata_bs_event_stream_name: ignored
audit_bs_messaging_metadata_bs_event_stream_consumer_dlq_name: ignored
logging:
level: