CF-3138 : Add cli command for ApplicationEvent list by paras-negi-flink · Pull Request #3315 · confluentinc/cli

Paras Negi (paras-negi-flink) · 2026-04-11T02:45:49Z

Release Notes

Breaking Changes

None

New Features

Added confluent flink application event list command to list Flink application events in Confluent Platform.

Bug Fixes

None

Checklist

What

This PR implements CF-3138 — CLI: List Flink Application events for the Confluent CLI, targeting Confluent Platform / CP Flink (CMF on-prem):

Adds a new command under confluent flink application:
- confluent flink application event list --environment <env> --application <app>
Wires this command to the CMF FlinkApplicationEvent REST API:
- GET /cmf/api/v1alpha1/environments/{envName}/applications/{appName}/events (paginated)
Adds CmfRestClient wrapper (ListApplicationEvents) and corresponding local types/output formatting, following existing patterns used for catalogs, databases, and compute pools.

Blast Radius

Scope is limited to new Flink application event command; existing CLI behavior is unchanged.
If something goes wrong:
- Impact is confined to users listing Flink application events via the new command.
- Listing may not show correct state for events; CMF remains the source of truth.
There are no breaking changes to existing commands, flags, or APIs. Reverting is straightforward (command + client wrapper).

References

Test & Review

Environment

Repo: confluentinc/cli
Branch: CF-3138
CMF: 2.3-SNAPSHOT
Kubernetes: local cluster with CMF deployed (cmf-service exposed via kubectl port-forward svc/cmf-service 8080:80 -n e2e)

Manual CLI validation

Help command for Flink Application event

parasnegi@C6V9RN9V2Y confluent_darwin_arm64_v8.0 % ./confluent flink application event -h
Manage Flink application events.

Usage:
  confluent flink application event [command]

Available Commands:
  list        List Flink application events.

Global Flags:
  -h, --help            Show help for this command.
      --unsafe-trace    Equivalent to -vvvv, but also log HTTP requests and responses which might contain plaintext secrets.
  -v, --verbose count   Increase verbosity (-v for warn, -vv for info, -vvv for debug, -vvvv for trace).

Use "confluent flink application event [command] --help" for more information about a command.

List Application events for a running Flink Application

parasnegi@C6V9RN9V2Y confluent_darwin_arm64_v8.0 % ./confluent flink application event list --environment test --application test-application --url http://localhost:8080 --output yaml
- apiVersion: cmf.confluent.io/v1alpha1
  kind: FlinkApplicationEvent
  metadata:
    name: f0b0802c-7fd9-4f37-8486-b97c1108ce69
    uid: f0b0802c-7fd9-4f37-8486-b97c1108ce69
    creationTimestamp: "2026-04-10T12:30:03.252Z"
    flinkApplicationInstance: aa96ecac-e748-4c21-8eeb-de08ccb74220
    labels: {}
    annotations: {}
  status:
    message: Flink job status changed from RECONCILING to RUNNING
    type: JOB_STATUS
- apiVersion: cmf.confluent.io/v1alpha1
  kind: FlinkApplicationEvent
  metadata:
    name: e5152a06-b603-40f2-bd54-879809fab13d
    uid: e5152a06-b603-40f2-bd54-879809fab13d
    creationTimestamp: "2026-04-10T12:29:53.228Z"
    flinkApplicationInstance: aa96ecac-e748-4c21-8eeb-de08ccb74220
    labels: {}
    annotations: {}
  status:
    message: Flink job status changed from RUNNING to RECONCILING
    type: JOB_STATUS

confluent-cla-assistant · 2026-04-11T02:46:02Z

🎉 All Contributor License Agreements have been signed. Ready to merge.
_{Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.}

Copilot

Pull request overview

Adds a new on-prem (CMF) CLI subcommand to list Flink application events, including CMF client support, test-server routing/handler coverage, and golden/integration test fixtures.

Changes:

Introduce confluent flink application event list and wire it into the existing flink application command tree.
Add CMF REST client support for listing application events with pagination.
Extend the on-prem test server + integration tests and add/update golden fixtures (help + output formats).

Reviewed changes

Copilot reviewed 17 out of 17 changed files in this pull request and generated 1 comment.

Show a summary per file

File	Description
`internal/flink/command_application.go`	Registers the new `application event` command under `flink application`.
`internal/flink/command_application_event.go`	Adds the `event` command group and SDK→local event conversion types for serialized output.
`internal/flink/command_application_event_list.go`	Implements `event list` command behavior, output formatting (human/json/yaml), and required flags.
`pkg/flink/cmf_rest_client.go`	Adds `ListApplicationEvents()` CMF client method with page iteration.
`test/test-server/flink_onprem_router.go`	Adds test-server route for the events endpoint.
`test/test-server/flink_onprem_handler.go`	Implements mock handler returning paged application events for integration tests.
`test/flink_onprem_test.go`	Adds integration test cases covering missing flags + human/json/yaml outputs + empty result.
`test/fixtures/output/flink/application/help-onprem.golden`	Updates `flink application` help output to include the new `event` subcommand.
`test/fixtures/output/flink/application/event/help-onprem.golden`	Adds help golden for `flink application event`.
`test/fixtures/output/flink/application/event/list-help-onprem.golden`	Adds help golden for `flink application event list`.
`test/fixtures/output/flink/application/event-list-*.golden`	Adds integration output fixtures for missing flags / empty / human / json / yaml.
`test/fixtures/output/flink/application/event-list-help-onprem.golden`	Adds a duplicate help fixture (not used by help test harness).

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Copilot · 2026-04-11T02:50:26Z

+List Flink application events.
+
+Usage:
+  confluent flink application event list [flags]
+
+Flags:
+      --environment string                  REQUIRED: Name of the Flink environment.
+      --application string                  REQUIRED: Name of the Flink application.
+      --url string                          Base URL of the Confluent Manager for Apache Flink (CMF). Environment variable "CONFLUENT_CMF_URL" may be set in place of this flag.
+      --client-key-path string              Path to client private key for mTLS authentication. Environment variable "CONFLUENT_CMF_CLIENT_KEY_PATH" may be set in place of this flag.
+      --client-cert-path string             Path to client cert to be verified by Confluent Manager for Apache Flink. Include for mTLS authentication. Environment variable "CONFLUENT_CMF_CLIENT_CERT_PATH" may be set in place of this flag.
+      --certificate-authority-path string   Path to a PEM-encoded Certificate Authority to verify the Confluent Manager for Apache Flink connection. Environment variable "CONFLUENT_CMF_CERTIFICATE_AUTHORITY_PATH" may be set in place of this flag.
+  -o, --output string                       Specify the output format as "human", "json", or "yaml". (default "human")
+
+Global Flags:
+  -h, --help            Show help for this command.
+      --unsafe-trace    Equivalent to -vvvv, but also log HTTP requests and responses which might contain plaintext secrets.
+  -v, --verbose count   Increase verbosity (-v for warn, -vv for info, -vvv for debug, -vvvv for trace).


TestHelp fixtures for leaf commands are expected under test/fixtures/output/<cmd path>/ (e.g., .../event/list-help-onprem.golden). This file duplicates the correct fixture at test/fixtures/output/flink/application/event/list-help-onprem.golden and is not referenced by the help test harness, so it’s dead weight and can cause confusion. Consider deleting this duplicate fixture and keeping only the path-based one.

Suggested change

List Flink application events.

Usage:

confluent flink application event list [flags]

Flags:

--environment string REQUIRED: Name of the Flink environment.

--application string REQUIRED: Name of the Flink application.

--url string Base URL of the Confluent Manager for Apache Flink (CMF). Environment variable "CONFLUENT_CMF_URL" may be set in place of this flag.

--client-key-path string Path to client private key for mTLS authentication. Environment variable "CONFLUENT_CMF_CLIENT_KEY_PATH" may be set in place of this flag.

--client-cert-path string Path to client cert to be verified by Confluent Manager for Apache Flink. Include for mTLS authentication. Environment variable "CONFLUENT_CMF_CLIENT_CERT_PATH" may be set in place of this flag.

--certificate-authority-path string Path to a PEM-encoded Certificate Authority to verify the Confluent Manager for Apache Flink connection. Environment variable "CONFLUENT_CMF_CERTIFICATE_AUTHORITY_PATH" may be set in place of this flag.

-o, --output string Specify the output format as "human", "json", or "yaml". (default "human")

Global Flags:

-h, --help Show help for this command.

--unsafe-trace Equivalent to -vvvv, but also log HTTP requests and responses which might contain plaintext secrets.

-v, --verbose count Increase verbosity (-v for warn, -vv for info, -vvv for debug, -vvvv for trace).

sonarqube-confluent · 2026-04-11T03:46:40Z

Quality Gate passed

Issues
6 New issues
3 Fixed issues
0 Accepted issues

Measures
0 Security Hotspots
95.9% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube

Add cli command for ApplicationEvent list

06f8e02

Copilot AI review requested due to automatic review settings April 11, 2026 02:45

Copilot started reviewing on behalf of Paras Negi (paras-negi-flink) April 11, 2026 02:46 View session

Copilot AI reviewed Apr 11, 2026

View reviewed changes

Fix suggested by copilot and claude review

be210a1

Paras Negi (paras-negi-flink) changed the title ~~Add cli command for ApplicationEvent list~~ CF-3136 : Add cli command for ApplicationEvent list May 13, 2026

Paras Negi (paras-negi-flink) marked this pull request as ready for review May 13, 2026 18:13

Paras Negi (paras-negi-flink) requested a review from a team as a code owner May 13, 2026 18:13

Paras Negi (paras-negi-flink) changed the title ~~CF-3136 : Add cli command for ApplicationEvent list~~ CF-3138 : Add cli command for ApplicationEvent list May 19, 2026

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

CF-3138 : Add cli command for ApplicationEvent list#3315

CF-3138 : Add cli command for ApplicationEvent list#3315
Paras Negi (paras-negi-flink) wants to merge 2 commits into
mainfrom
CF-3138

Paras Negi (paras-negi-flink) commented Apr 11, 2026 •

edited

Loading

Uh oh!

confluent-cla-assistant Bot commented Apr 11, 2026

Uh oh!

Copilot AI left a comment

Uh oh!

Copilot AI Apr 11, 2026

Uh oh!

sonarqube-confluent Bot commented Apr 11, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Conversation

Paras Negi (paras-negi-flink) commented Apr 11, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Release Notes

Checklist

What

Blast Radius

References

Test & Review

Uh oh!

confluent-cla-assistant Bot commented Apr 11, 2026

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Copilot AI Apr 11, 2026

Choose a reason for hiding this comment

Uh oh!

sonarqube-confluent Bot commented Apr 11, 2026

Quality Gate passed

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Paras Negi (paras-negi-flink) commented Apr 11, 2026 •

edited

Loading