Add first-class Kafka trigger and output binding support with Schema Registry URL

src/app.ts

@@ -11,6 +11,7 @@ import {
     HttpHandler,
     HttpMethod,
     HttpMethodFunctionOptions,
+    KafkaFunctionOptions,
     McpToolFunctionOptions,
     MySqlFunctionOptions,
     ServiceBusQueueFunctionOptions,
@@ -146,6 +147,10 @@ export function webPubSub(name: string, options: WebPubSubFunctionOptions): void
     generic(name, convertToGenericOptions(options, trigger.webPubSub));
 }
 
+export function kafka(name: string, options: KafkaFunctionOptions): void {
+    generic(name, convertToGenericOptions(options, trigger.kafka));
+}
+
 /**
  * Registers an MCP Tool function in your app.
  * This function is triggered by MCP Tool events and allows you to define the behavior of the function.

src/output.ts

@@ -12,6 +12,8 @@ import {
     GenericOutputOptions,
     HttpOutput,
     HttpOutputOptions,
+    KafkaOutput,
+    KafkaOutputOptions,
     MySqlOutput,
     MySqlOutputOptions,
     ServiceBusQueueOutput,
@@ -115,6 +117,13 @@ export function webPubSub(options: WebPubSubOutputOptions): WebPubSubOutput {
     });
 }
 
+export function kafka(options: KafkaOutputOptions): KafkaOutput {
+    return addOutputBindingName({
+        ...options,
+        type: 'kafka',
+    });
+}
+
 export function generic(options: GenericOutputOptions): FunctionOutput {
     return addOutputBindingName(options);
 }

src/trigger.ts

@@ -12,6 +12,8 @@ import {
     GenericTriggerOptions,
     HttpTrigger,
     HttpTriggerOptions,
+    KafkaTrigger,
+    KafkaTriggerOptions,
     McpToolTrigger,
     McpToolTriggerOptions,
     MySqlTrigger,
@@ -129,6 +131,13 @@ export function webPubSub(options: WebPubSubTriggerOptions): WebPubSubTrigger {
     });
 }
 
+export function kafka(options: KafkaTriggerOptions): KafkaTrigger {
+    return addTriggerBindingName({
+        ...options,
+        type: 'kafkaTrigger',
+    });
+}
+
 /**
  * Creates an MCP Tool trigger configuration.
  * This function is used to define an MCP Tool trigger for an Azure Function.

types/app.d.ts

@@ -5,6 +5,7 @@ import { CosmosDBFunctionOptions } from './cosmosDB';
 import { EventGridEvent, EventGridFunctionOptions } from './eventGrid';
 import { EventHubFunctionOptions } from './eventHub';
 import { GenericFunctionOptions } from './generic';
+import { KafkaFunctionOptions } from './kafka';
 import { HttpFunctionOptions, HttpHandler, HttpMethodFunctionOptions } from './http';
 import { McpToolFunctionOptions } from './mcpTool';
 import { MySqlFunctionOptions } from './mySql';
@@ -182,6 +183,13 @@ export function sql<T = unknown>(name: string, options: SqlFunctionOptions<T>):
  */
 export function mySql<T = unknown>(name: string, options: MySqlFunctionOptions<T>): void;
 
+/**
+ * Registers a function in your app that will be triggered whenever a message is added to a Kafka topic
+ * @param name The name of the function. The name must be unique within your app and will mostly be used for your own tracking purposes
+ * @param options Configuration options describing the inputs, outputs, and handler for this function
+ */
+export function kafka<T = unknown>(name: string, options: KafkaFunctionOptions<T>): void;
+
 /**
  * Registers a generic function in your app that will be triggered based on the type specified in `options.trigger.type`
  * Use this method if your desired trigger type does not already have its own method

types/index.d.ts

@@ -10,6 +10,7 @@ export * from './cosmosDB.v4';
 export * from './eventGrid';
 export * from './eventHub';
 export * from './generic';
+export * from './kafka';
 export * from './hooks/appHooks';
 export * from './hooks/HookContext';
 export * from './hooks/invocationHooks';