Using Kafka Streams with Event Streams

Kafka Streams is a stream processing library that is part of the Apache Kafka project. It simplifies building applications that process and analyze data in Kafka.

The topic APIs work with Event Streams with no setup required. Specify your SASL credentials by using sasl.jaas.config or a JAAS file and set replication.factor to 3.

Ensure that you use Streams version 0.10.2, or later.

See the following example:

    props.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, "3");
    props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
    props.put("security.protocol","SASL_SSL");
    props.put("sasl.mechanism","PLAIN");
    props.put("ssl.protocol","TLSv1.2");
    props.put("ssl.enabled.protocols","TLSv1.2");
    props.put("sasl.jaas.config","org.apache.kafka.common.security.plain.PlainLoginModule required username=\"USERNAME\" password=\"PASSWORD\";");

Where BOOTSTRAP_SERVERS, USERNAME, and PASSWORD are the values from your Event Streams Service Credentials tab in IBM Cloud.