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}`.