diff --git a/plugins/kafka/src/constants.ts b/plugins/kafka/src/constants.ts
index c19651ef04..652911a91f 100644
--- a/plugins/kafka/src/constants.ts
+++ b/plugins/kafka/src/constants.ts
@@ -14,4 +14,4 @@
  * limitations under the License.
  */
 export const KAFKA_CONSUMER_GROUP_ANNOTATION =
-  'kafka.apache.org/consumer-group';
+  'kafka.apache.org/consumer-groups';