IBM Event Automation incorporates both IBM proprietary and open-source components, including Apache Kafka and Apache Flink. In case of a problem with any of these components, IBM will investigate, identify, and provide a fix when possible. Where the fix applies to an open-source component, IBM will work with the open-source community to contribute the fix to the open-source project as appropriate.
Event Streams and Kafka
The official Apache Kafka Java client libraries are included in Event Streams. If you encounter client-side issues when using Event Automation capabilities with clients that are not provided by IBM, IBM can assist you in working with the open-source community to resolve those issues.
Event Endpoint Management
Event Endpoint Management works with any Kafka distribution that faithfully supports the public-facing Kafka protocol.
The Kafka protocol is made up of many API keys. Each API key has a range of request and response versions. The Event Gateway supports the use of the following APIs by Kafka clients connecting to it:
Event Endpoint Management version | API key name | Supported API key request and response versions |
---|---|---|
11.1.5 and later | Produce | All |
11.1.5 and later | InitProducerId | All |
11.0.0 and later | Fetch | All |
11.0.0 and later | ListOffsets | All |
11.0.0 and later | Metadata | All |
11.0.0 and later | OffsetCommit | All |
11.0.0 and later | OffsetFetch | All |
11.0.0 and later | FindCoordinator | All |
11.0.0 and later | JoinGroup | All |
11.0.0 and later | Heartbeat | All |
11.0.0 and later | LeaveGroup | All |
11.0.0 and later | SyncGroup | All |
11.0.0 and later | SaslHandshake | All |
11.0.0 and later | ApiVersions | All |
11.0.0 and later | OffsetForLeaderEpoch | All |
11.0.0 and later | SaslAuthenticate | All |
11.0.0 and later | OffsetDelete | All |
Event Processing and Flink
For Apache Flink, support is provided if the following conditions are met:
-
A Flink instance deployed and managed by the IBM Operator for Apache Flink on the Red Hat OpenShift Container Platform or, in Event Processing version 1.0.5 and later, on any other Kubernetes platform that supports the Red Hat Universal Base Images (UBI) containers. Only session mode and application mode deployments are supported.
-
IBM supports the use of IBM Flink images with:
- Jobs authored in the Event Processing canvas
- Flink SQL code
- Java applications
-
The following Flink Java connectors are supported:
- Flink built-in connectors
- Kafka and Upsert Kafka
- JDBC
Note: The Apache Flink Web UI is provided for development purposes only.
Deprecated APIs
Deprecated Apache Flink APIs will be removed in future Flink updates and, as a result, any code that uses these deprecated APIs will not function with these future releases. It is strongly advised that users do not make use of any deprecated APIs to ensure that future Flink updates can be consumed. For a list of deprecated Java APIs, see the Apache Flink JavaDocs of the supported version.