feat(events): configure schema discovery on event bus

packages/@aws-cdk-testing/framework-integ/test/aws-events/test/integ.eventbus.js.snapshot/Stack.template.json

@@ -95,6 +95,30 @@
     },
     "StatementId": "cdk-Statement2"
    }
+  },
+  "BusSchemaDiscoveryE6A342A5": {
+   "Type": "AWS::EventSchemas::Discoverer",
+   "Properties": {
+    "CrossAccount": true,
+    "Description": {
+     "Fn::Join": [
+      "",
+      [
+       "Schema Discoverer for ",
+       {
+        "Ref": "BusEA82B648"
+       },
+       " Event Bus"
+      ]
+     ]
+    },
+    "SourceArn": {
+     "Fn::GetAtt": [
+      "BusEA82B648",
+      "Arn"
+     ]
+    }
+   }
   }
  },
  "Parameters": {

packages/@aws-cdk-testing/framework-integ/test/aws-events/test/integ.eventbus.ts

@@ -30,6 +30,8 @@ bus.addToResourcePolicy(new iam.PolicyStatement({
   resources: [bus.eventBusArn],
 }));
 
+bus.schemaDiscovery('SchemaDiscovery');
+
 new IntegTest(app, 'IntegTest-EventBusStack', {
   testCases: [stack],
 });

packages/aws-cdk-lib/aws-events/README.md

@@ -272,6 +272,22 @@ bus.archive('MyArchive', {
 });
 ```
 
+## Schema Discovery
+
+It is possible to automatically generate schemas in Schema Registry for events sent to an event bus. This is useful for discovering what events are sent to the event bus.
+
+```ts
+const bus = new events.EventBus(this, 'bus', {
+  eventBusName: 'MyCustomEventBus',
+  description: 'MyCustomEventBus',
+});
+
+bus.schemaDiscovery('MySchemaDiscovery', {
+  crossAccount: true,
+  description: 'MyCustomerEventBus Schema Discovery',
+});
+```
+
 ## Dead-Letter Queue for EventBus
 
 It is possible to configure a [Dead Letter Queue for an EventBus](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-rule-event-delivery.html#eb-rule-dlq). This is useful when you want to capture events that could not be delivered to any of the targets.

packages/aws-cdk-lib/aws-events/lib/event-bus.ts

@@ -1,11 +1,33 @@
 import { Construct } from 'constructs';
 import { Archive, BaseArchiveProps } from './archive';
 import { CfnEventBus, CfnEventBusPolicy } from './events.generated';
+import * as eventschemas from '../../aws-eventschemas';
 import * as iam from '../../aws-iam';
 import * as kms from '../../aws-kms';
 import * as sqs from '../../aws-sqs';
 import { ArnFormat, IResource, Lazy, Names, Resource, Stack, Token } from '../../core';
 
+/**
+ * Properties to configure schema discovery on an event bus
+ */
+interface SchemaDiscoveryProps {
+  /**
+   * Allows for the discovery of the event schemas that are sent to the event bus from another account
+   *
+   * @link https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-eventschemas-discoverer.html#cfn-eventschemas-discoverer-crossaccount
+   * @default - none
+   */
+  readonly crossAccount: boolean;
+
+  /**
+   * A description for the discoverer
+   *
+   * @link https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-eventschemas-discoverer.html#cfn-eventschemas-discoverer-description
+   * @default - none
+   */
+  readonly description: string;
+};
+
 /**
  * Interface which all EventBus based classes MUST implement
  */
@@ -50,6 +72,13 @@ export interface IEventBus extends IResource {
    */
   archive(id: string, props: BaseArchiveProps): Archive;
 
+  /**
+   * Create an EventBridge schema discoverer to automatically generate schemas based on events on this event bus.
+   *
+   * @param props Properties of the schema discoverer
+   */
+  schemaDiscovery(id: string, props?: SchemaDiscoveryProps): eventschemas.CfnDiscoverer;
+
   /**
    * Grants an IAM Principal to send custom events to the eventBus
    * so that they can be matched to rules.
@@ -175,6 +204,14 @@ abstract class EventBusBase extends Resource implements IEventBus {
     });
   }
 
+  public schemaDiscovery(id: string, props?: SchemaDiscoveryProps): eventschemas.CfnDiscoverer {
+    return new eventschemas.CfnDiscoverer(this, id, {
+      crossAccount: props?.crossAccount ?? true,
+      description: props?.description || `Schema Discoverer for ${this.eventBusName} Event Bus`,
+      sourceArn: this.eventBusArn,
+    });
+  }
+
   public grantPutEventsTo(grantee: iam.IGrantable): iam.Grant {
     return iam.Grant.addToPrincipal({
       grantee,