Sarwar Bhuiyan

Kafka store abstraction

1

This commit is a small commit to ensure that the KafkaSchemaRegistry class is only used from a limited number of places and that the SchemaRegistry interface is used. This would...

Extend parallel consumer to be able to include multiple consumers/producers of different clusters

2

There are a few use cases where a client application may be interested in consuming from multiple clusters and optionally produce to different kafka clusters: 1. In some data aggregation...

Added example with oauth/oidc example with CCloud logicalCluster and identityPoolId

12

The following example shows how to configure the producer with OAUTH. For Confluent Cloud where we need to pass extensions for "logicalCluster" and "identityPoolId" we need to pass some additional...

Fixed tokenizer to remove " from tokens as well as added Capitalized brand if found within tokens

compose file ``` version: '3.3' services: proton: image: [d.timeplus.com/timeplus-io/proton:latest](http://d.timeplus.com/timeplus-io/proton:latest) pull_policy: always environment: - PROTON_USER=proton - PROTON_PASSWORD=hello - TELEMETRY_ENABLED=false ports: - 3218:3218 #http port for JDBC driver, default streaming mode -...