免打扰请勿打扰功能，用于电子邮件，短信等通知

我创建了微服务，用于发送多个通知，例如电子邮件，短信等，这些通知正在消耗来自卡夫卡的通知。我希望将DDN之类的用户偏好视为用户在指定的DND期限内不应该收到通知。

我如何实现此DND功能，因为kafka会不断向我发送带有时间戳（发送消息的日期和时间）的消息，该消息应在何时触发通知并确认用户在订阅的DND期内不会收到这些通知？

我可以为此获得一些帮助吗？

我对Kafka并不完全有经验，但是我对微服务架构和消息队列有一定的了解。

由于微服务正在使用Queue或Kafka中的任务，因此可以在使用微服务中实现DND。可能需要执行其他任务，以检查用户是否在DND中，然后发送通知。

但是，微服务是特定于任务的，最好只发送通知，所以也许可以修改将任务发布到Kafka的应用程序/微服务。

微服务A-> Kafka->通知微服务（B）

微服务A可以在传递给Kafka之前检查DND或

微服务A可以将用户DND时间段信息以及其他通知详细信息附加到Kafka。现在，当B从Kafka接收/消费时，它会检查它是否在DND期限内，并且会简单地忽略它，否则。

----在第一个评论之后添加----

我认为DND内的通知可以被丢弃。这是我们以后可以发送通知的方法。

----答案基于以上架构----

要稍后发送通知而不丢弃通知，您可以创建另一个本地队列（数组或任何可行的数据结构）或使用内存队列（例如Redis）。

现在根据我之前的建议，我们现在可以避免发送并放入新创建的队列中，而不是丢弃DND中的通知。

微服务B可以有一个调度程序，可以说每15分钟一次。

此外，假设如我之前所述，通知将具有DND参数（由于此队列包含已跳过的通知，因此不再需要实际发送时间或有效时间）

现在每隔15分钟（或设置了任何时间），微服务B可以检查此队列的内容并仅在其不在DND范围内时发送通知，最后将其从队列中删除。

如果时间仍在DND中，我们会将通知保留在队列中而不将其删除，因此它将在15分钟（设置的时间）之后再次被处理。

最后，如果B已经超载，我们可以创建另一个简单的微服务，如果通知在DND内，它将每15分钟检查一次此新队列，并将其传递给微服务B发送实际通知。

使用通知主题中的消息后，可以根据DND逻辑分离消息。发布您可以将其写回另一个Kafka主题，例如dnd-notifications并从那里阅读的内容。由于Kafka用于exactly-once传递，因此您必须将dnd消息推送到新主题。

9月26日编辑：

在事后看来，将您的dnd通知放入一个单独的主题将无法正常工作，例如““如果用户的dnd期限持续超过7天该怎么办”“。默认情况下，Kafka的消息保留时间为7天（您可以增加），但是kafka并非用于存储。

您需要做的是涉及一个数据库并拥有2个微服务。一个微服务将是一个消费微服务，它将读取kafka并使用标志将消息写入数据库中的表（即is_read，如果消息已经推送给用户并已读取，则为true）。默认情况下，is_read对于任何新消息均为假。

第二个微服务将是考虑到用户dnd-configuration实际将通知推送出去的微服务。它应该从数据库中读取所有未读消息表，检查用户dnd-config，然后推送到该用户。这第二项服务可以定期轮询数据库并发送未读消息。