Skip to content

Commit

Permalink
update to add ventress
Browse files Browse the repository at this point in the history
  • Loading branch information
jbcodeforce committed Jul 26, 2022
1 parent b141b6b commit 2757434
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 0 deletions.
1 change: 1 addition & 0 deletions docs/getting-started/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ App details: [https://ibm.github.io/event-streams/getting-started/generating-sta
| Mandalorian | [https://cpd-cp4i.apps.mandalorian.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted](https://cpd-cp4i.apps.mandalorian.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted) |
| Cody| [https://cpd-cp4i.apps.cody.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted](https://cpd-cp4i.apps.cody.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted) |
| Grievous | [https://cpd-cp4i.apps.grievous.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted](https://cpd-cp4i.apps.grievous.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted) |
| Ventress | [ https://cpd-cp4i.apps.ventress.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted]( https://cpd-cp4i.apps.ventress.coc-ibm.com/integration/kafka-clusters/cp4i-eventstreams/es-demo/gettingstarted) |


![](./images/lab-1-es-1.png)
Expand Down
1 change: 1 addition & 0 deletions docs/getting-started/mm2.md
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,7 @@ Use one of the following KafkaConnect_URL depending on the Openshift Cluster tha
| Mandalorian | [connect-cp4i-eventstreams.apps.mandalorian.coc-ibm.com](https://cconnect-cp4i-eventstreams.apps.mandalorian.coc-ibm.com) |
| Cody| [connect-cp4i-eventstreams.apps.cody.coc-ibm.com](https://cconnect-cp4i-eventstreams.apps.cody.coc-ibm.com) |
| Grievous | [connect-cp4i-eventstreams.apps.grievous.coc-ibm.com](https://cconnect-cp4i-eventstreams.apps.grievous.coc-ibm.com) |
| ventress | [cconnect-cp4i-eventstreams.apps.ventress.coc-ibm.com]( https://cconnect-cp4i-eventstreams.apps.ventress.coc-ibm.com/) |

### 3. Kafka Connect

Expand Down
1 change: 1 addition & 0 deletions docs/lab2/kstream.md
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ Then Kstream offers a lot of functions to process the records. Below is a quick
| [aggregate](https://kafka.apache.org/30/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate) | Aggregate the values of records in this stream by the grouped key | .aggregate(() -> new StoreInventory(), (store , newItem, existingStoreInventory) -> existingStoreInventory.updateStockQuantity(store,newItem), materializeAsStoreInventoryKafkaStore()); |
| [split](https://kafka.apache.org/30/javadoc/org/apache/kafka/streams/kstream/KStream.html#split()) | Split a stream into branches| items.split(Named.as("B-")) |
| [BranchedKStream](https://kafka.apache.org/30/javadoc/org/apache/kafka/streams/kstream/BranchedKStream.html) | Branches the records in the original stream based on the predicates supplied for the branch definitions. | .branch((k,v) -> (v.storeName == null), Branched.as("wrong-tx")).defaultBranch(Branched.as("good-tx")); branches.get("B-good-tx").to(outTopicName); branches.get("B-wrong-tx").to(deadLetterTopicName); |
| [selectKey](https://kafka.apache.org/32/javadoc/org/apache/kafka/streams/kstream/KStream.html#selectKey(org.apache.kafka.streams.kstream.KeyValueMapper)) | Change the key of a record |

### KTable

Expand Down

0 comments on commit 2757434

Please sign in to comment.