---
title: "Changes to Create a KafkaConsume plugin"
method: POST
path: "/v2/control-planes/{controlPlaneId}/core-entities/plugins#KafkaConsume"
---

# Changes to Create a KafkaConsume plugin

`POST /v2/control-planes/{controlPlaneId}/core-entities/plugins#KafkaConsume`

> Every recorded change to this endpoint, newest first.

## Timeline

Changed in 12 of 52 revisions.

- **2026-07-06** `36da5cb9a674` — 1 warning, 7 info
- **2026-06-11** `62c54f1094bb` — 1 breaking, 1 info
- **2026-04-24** `7d6a643707d9` — 2 info
- **2026-01-13** `ad02b4e24eb2` — 4 info
- **2025-11-11** `28774c89f2cb` — 4 breaking, 4 info
- **2025-10-29** `19e869275e28` — 10 breaking, 4 warning, 21 info
- **2025-09-16** `f03059016622` — 5 breaking
- **2025-08-22** `96118a9cd7f4` — 19 breaking, 39 info
- **2025-07-22** `2c77aeaee5fb` — 5 breaking, 1 warning, 8 info
- **2025-06-17** `c308b7426a7c` — 2 breaking
- **2025-05-21** `69704304ad5f` — 2 info
- **2025-05-01** `351c07039f3c` — 1 info

## Changes

- **2026-07-06** `36da5cb9a674` — 1 warning, 7 info
  - added the new `OAUTHBEARER` enum value to the `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/mechanism` response property for the response status `201`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/oauthbearer`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/consumer_group`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/error_handling`
  - added the new `OAUTHBEARER` enum value to the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/mechanism`
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/oauthbearer` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/consumer_group` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/error_handling` to the response with the `201` status
- **2026-06-11** `62c54f1094bb` — 1 breaking, 1 info
  - the request property `allOf[#/components/schemas/PluginBase]/partials/items/path` became required
  - the response property `allOf[#/components/schemas/PluginBase]/partials/items/path` became required for the status `201`
- **2026-04-24** `7d6a643707d9` — 2 info
  - added the new optional request property `allOf[#/components/schemas/PluginBase]/condition`
  - added the optional property `allOf[#/components/schemas/PluginBase]/condition` to the response with the `201` status
- **2026-01-13** `ad02b4e24eb2` — 4 info
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/enforce_latest_offset_reset`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/ssl_verify`
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/enforce_latest_offset_reset` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/ssl_verify` to the response with the `201` status
- **2025-11-11** `28774c89f2cb` — 4 breaking, 4 info
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2/token_headers` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2/token_post_args` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2/token_headers` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2/token_post_args` became nullable for the status `201`
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2/token_headers` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2/token_post_args` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2/token_headers` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2/token_post_args` became nullable
- **2025-10-29** `19e869275e28` — 10 breaking, 4 warning, 21 info
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication` became not nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry` became not nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security` became not nullable
  - the `allOf[#/components/schemas/KafkaConsumePluginConfig]/name` request property type changed from `string` to no type
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication` became optional for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry` became optional for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication` became optional for the status `201`
  - the `allOf[#/components/schemas/KafkaConsumePluginConfig]/name` response's property type changed from `string` to no type for status `201`
  - removed the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/service`
  - removed the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/service` from the response with the `201` status
  - added the new `oauth2` enum value to the `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/mode` response property for the response status `201`
  - added the new `oauth2` enum value to the `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/mode` response property for the response status `201`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/dlq_topic`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/enable_dlq`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/message_by_lua_functions`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2_client`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2_client`
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication` became optional
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry` became optional
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication` became optional
  - added the new `oauth2` enum value to the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/mode`
  - added the new `oauth2` enum value to the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/mode`
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/dlq_topic` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/enable_dlq` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/message_by_lua_functions` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/oauth2_client` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2` to the response with the `201` status
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/oauth2_client` to the response with the `201` status
- **2025-09-16** `f03059016622` — 5 breaking
  - the request property `allOf[#/components/schemas/PluginBase]/partials/items/name` became not nullable
  - the request property `allOf[#/components/schemas/PluginBase]/partials/items/path` became not nullable
  - the `allOf[#/components/schemas/PluginBase]/id` request property's minLength was increased from `0` to `1`
  - the `allOf[#/components/schemas/PluginBase]/name` request property's minLength was increased from `0` to `1`
  - the `allOf[#/components/schemas/PluginBase]/partials/items/id` request property's minLength was increased from `0` to `1`
- **2025-08-22** `96118a9cd7f4` — 19 breaking, 39 info
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/password` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/tokenauth` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/user` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/cluster_name` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/basic` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/ttl` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/url` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/certificate_id` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/ssl` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/basic` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/ttl` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/url` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/PluginBase]/partials/items/name` became nullable for the status `201`
  - the response property `allOf[#/components/schemas/PluginBase]/partials/items/path` became nullable for the status `201`
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/password` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/tokenauth` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/authentication/user` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/cluster_name` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/authentication/basic` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/ttl` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry/confluent/url` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/certificate_id` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/security/ssl` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/authentication/basic` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/ttl` became nullable
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry/confluent/url` became nullable
  - the request property `allOf[#/components/schemas/PluginBase]/partials/items/name` became nullable
  - the request property `allOf[#/components/schemas/PluginBase]/partials/items/path` became nullable
  - the `auto_offset_reset` request property default value `latest` was added
  - the `commit_strategy` request property default value `auto` was added
  - …18 more
- **2025-07-22** `2c77aeaee5fb` — 5 breaking, 1 warning, 8 info
  - added the new required request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry`
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config` became required
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/bootstrap_servers` became required
  - the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics` became required
  - the response property `allOf[#/components/schemas/PluginBase]/tags` became nullable for the status `201`
  - added the new `websocket` enum value to the `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/mode` response property for the response status `201`
  - added the new optional request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry`
  - the request property `allOf[#/components/schemas/PluginBase]/tags` became nullable
  - added the new `websocket` enum value to the request property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/mode`
  - added the optional property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/schema_registry` to the response with the `201` status
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config` became required for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/bootstrap_servers` became required for the status `201`
  - the response property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics` became required for the status `201`
  - added the required property `allOf[#/components/schemas/KafkaConsumePluginConfig]/config/topics/items/schema_registry` to the response with the `201` status
- **2025-06-17** `c308b7426a7c` — 2 breaking
  - the `allOf[#/components/schemas/KafkaConsumePluginConfig]/protocols` request property format changed from no format to `set`
  - the `allOf[#/components/schemas/KafkaConsumePluginConfig]/protocols` response's property format changed from no format to `set` for status `201`
- **2025-05-21** `69704304ad5f` — 2 info
  - added the new optional request property `allOf[#/components/schemas/PluginBase]/partials`
  - added the optional property `allOf[#/components/schemas/PluginBase]/partials` to the response with the `201` status
- **2025-05-01** `351c07039f3c` — 1 info
  - endpoint added

---

[Operation](https://skmtc.dev/kong/apis/konnect-api/docs/v2/control-planes/:controlPlaneId/core-entities/plugins#KafkaConsume/post.md) · [API](https://skmtc.dev/kong/apis/konnect-api.md) · [Page](https://skmtc.dev/kong/apis/konnect-api/changes/v2/control-planes/:controlPlaneId/core-entities/plugins#KafkaConsume/post)
