Event notification (Read) block
The event_notification_read block consumes event notifications from Kafka topics as a source block in a Connect+ dataflow. It listens to one or more specified Kafka topics and triggers the dataflow when a matching event notification is received. The block supports a searchable topic selection dropdown and an advanced consumer group configuration.
When to use this block
Use this block when a Capillary platform event, such as a points issuance, tier upgrade, transaction, or reward event should trigger your dataflow.
Prerequisites
Before configuring this block, make sure you have:
- Identified the Capillary event topic or topics your dataflow should listen to
Standard properties
| Field name | Required | Description |
|---|---|---|
| Block name | No | A name for the block instance. |
| Kafka topics comma separated | Yes | The Kafka topic or topics to consume event notifications from. Select one or more topics from the dropdown. The dropdown is searchable. Available topics include: rewardIssued, rewardExpiryReminder, streakCustomerUnEnrolment, customerSubscription, issueRewardFailure, groupUpdated, notInterestedBillAdded, promisedToCurrentPointsConversion, groupCreated, pointsTransferredReceived, revokeIssuedPromotion, partnerProgramUpdated, pointsIssued, supplementaryMembershipExpiryReminder, targetCustomerEnrolment, updateRewardTransaction, unifiedTargetsUnAchieved, partnerProgramDelinked, badgeEarned, cartPromotionIssued, rewardCreated, manualPointsAdjustment, redeemedPointsReversed, cartPromotionEarned, targetCustomerUnenrolment, communicationMessageOpened, tierDowngraded, pointsTransferredInitiated, tierUpgraded, loyaltyCustomerMerge, partnerProgramLinked, requestUpdated, targetPeriodStarted, promotionIssued, manualAlternateCurrencyAdjustment, pointsExpiryChange, unifiedTargetsAchieved, pointsExpired, rewardUpdated, transactionUpdated, customerAdded, issueRewardPermanentFailure, communicationMessageClicked, streakEnd, groupMemberRemoved, targetValueAchieved, communicationMessageUndelivered, singlePointsExpiryUpdated, alternateCurrenciesIssued, transactionRejected, tierDowngradeReminder, groupMemberAdded, issuedPointsReversed, revokeEarnedPromotion, pointsContributionToGroup, streakLevelUnAchieved, CouponRedeem, retroBillAdded, pointsExpiryReminder, promotionEarned, cartPromotionRevoked, pointsRedeemed, streakStart, transactionAdded, rejectedTransactionRetrigger, streakCustomerEnrolment, promotionCreated, CouponIssue, promisedToCurrentAlternateCurrencyConversion, streakLevelAchieved, promotionUpdated, tierRenewed, targetAchievedValueUpdated, cardUpdated, cartPromotionRedeemed, targetValueUpdated, customerUpdated, issuedAlternateCurrenciesReversed, requestWorkflowEvent, targetPeriodCompleted. |
Advanced properties
⚠️ Advanced properties for Consume Event Notifications. Make changes to advanced properties only if you know what you are doing.
Advanced properties for Consume Event Notifications.
| Field name | Required | Description |
|---|---|---|
| Consumer Group Id | No | The consumer group ID used to identify this block's Kafka consumer. Default value: ${neoDataflowId}. If the value is null or empty (set to '' or 'null'), the default value is not substituted. This will result in no events being delivered and the dataflow will not trigger. To ensure correct behavior, omit this field or use the default variable ${neoDataflowId}. |
