Skip to content

Commit f714a94

Browse files
committed
Refactor Kafka trigger documentation to consolidate versioning and remove redundant Event Hubs sections
1 parent fe0b126 commit f714a94

1 file changed

Lines changed: 8 additions & 52 deletions

File tree

articles/azure-functions/functions-bindings-kafka-trigger.md

Lines changed: 8 additions & 52 deletions
Original file line numberDiff line numberDiff line change
@@ -673,47 +673,29 @@ In the Python v1 model, you define your trigger in the `function.json` with your
673673
674674
These examples show how to define a Kafka trigger for a function that reads a Kafka message.
675675
676-
# [Confluent](#tab/confluent/v2)
676+
# [Version 2](#tab/v2)
677677
678678
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger.py" range="10-22" :::
679679
680-
# [Event Hubs](#tab/event-hubs/v2)
681-
682-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger.py" range="10-22" :::
683-
684-
# [Confluent](#tab/confluent/v1)
680+
# [Version 1](#tab/v1)
685681
686-
This `function.json` file defines the trigger for the Confluent provider:
682+
This `function.json` file defines the trigger:
687683
688684
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTrigger/function.confluent.json" :::
689685
690686
This code runs when the function is triggered:
691687
692688
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTrigger/main.py" :::
693689
694-
# [Event Hubs](#tab/event-hubs/v1)
695-
696-
This `function.json` file defines the trigger for the Event Hubs provider:
697-
698-
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTrigger/function.eventhub.json" :::
699-
700-
This code runs when the function is triggered:
701-
702-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTrigger/main.py" :::
703-
704690
---
705691
706692
This example receives events in a batch by setting the `cardinality` value to `many`.
707693
708-
# [Confluent](#tab/confluent/v2)
694+
# [Version 2](#tab/v2)
709695
710696
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger.py" range="24-38" :::
711697
712-
# [Event Hubs](#tab/event-hubs/v2)
713-
714-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger.py" range="24-38" :::
715-
716-
# [Confluent](#tab/confluent/v1)
698+
# [Version 1](#tab/v1)
717699
718700
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerMany/function.confluent.json" :::
719701
@@ -725,50 +707,24 @@ This code logs the header data:
725707
726708
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerManyWithHeaders/__init__.py" :::
727709
728-
# [Event Hubs](#tab/event-hubs/v1)
729-
730-
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerMany/function.eventhub.json" :::
731-
732-
This code parses the array of events and logs the event data:
733-
734-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerMany/main.py" :::
735-
736-
This code logs the header data:
737-
738-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerManyWithHeaders/__init__.py" :::
739-
740710
---
741711
742712
You can define a generic [Avro schema] for the event passed to the trigger.
743713
744-
# [Confluent](#tab/confluent/v2)
714+
# [Version 2](#tab/v2)
745715
746716
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger_avro.py" range="24-37" :::
747717
748-
# [Event Hubs](#tab/event-hubs/v2)
749-
750-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python-v2/kafka_trigger_avro.py" range="24-37" :::
751-
752-
# [Confluent](#tab/confluent/v1)
718+
# [Version 1](#tab/v1)
753719
754-
This `function.json` defines the trigger for the Confluent provider with a generic Avro schema:
720+
This `function.json` defines the trigger with a generic Avro schema:
755721
756722
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerAvroGeneric/function.confluent.json" :::
757723
758724
This code runs when the function is triggered:
759725
760726
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerAvroGeneric/main.py" :::
761727
762-
# [Event Hubs](#tab/event-hubs/v1)
763-
764-
This `function.json` defines the trigger for the Confluent provider with a generic Avro schema:
765-
766-
:::code language="json" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerAvroGeneric/function.eventhub.json" :::
767-
768-
This code runs when the function is triggered:
769-
770-
:::code language="python" source="~/azure-functions-kafka-extension/samples/python/KafkaTriggerAvroGeneric/main.py" :::
771-
772728
---
773729
774730
# [Version 2](#tab/v2)

0 commit comments

Comments
 (0)