Running KSQL on IBM Event Streams

KSQL uses the RDBMS SQL syntax to turn the development of a streaming application into constructing RDBMS objects with the old familiar friend, SQL statement. This greatly reduced the complexity of stream application, and make it more like a dynamic “what if” exploring scenario with different SQL statements.

This paper explores how to run a testing KSQL engine with IBM Event Streams in an OpenShift Kubernetes environment.

1. Prepare connection properties to IBM Event Streams

Get all the required connection properties from the IBM event streams console, as listed below,

• API Key
• Java truststore JKS file, es-cert.jks
• Bootstrap server

It’s noted though we are going to run the KSQL within the Kubernetes cluster, the connection to the IBM event is still going through the exposed bootstrap server as the same as the external connections.

2. Setup OpenShift namespace and SCC

Create namespace, assign the anyuid SCC to the default service account.

oc new-project streaming
oc adm policy add-scc-to-user anyuid -z default