Skip to content

Add unit tests for KStreamImpl#66

Merged
Guozhang Wang (guozhangwang) merged 2 commits into
confluentinc:streamingfrom
guozhangwang:KStreamImplTest
Sep 22, 2015
Merged

Add unit tests for KStreamImpl#66
Guozhang Wang (guozhangwang) merged 2 commits into
confluentinc:streamingfrom
guozhangwang:KStreamImplTest

Conversation

@guozhangwang

Copy link
Copy Markdown

ymatsuda

Also I am thinking if we can rename KStream.sendTo() to just KStream.to(), which is more symmetric to builder.from().

@ymatsuda

Copy link
Copy Markdown

lgtm
sendTo() -> to() is fine with me.

Guozhang Wang (guozhangwang) added a commit that referenced this pull request Sep 22, 2015
@guozhangwang Guozhang Wang (guozhangwang) merged commit 58c7413 into confluentinc:streaming Sep 22, 2015
@guozhangwang Guozhang Wang (guozhangwang) deleted the KStreamImplTest branch October 7, 2016 21:45
José Armando García Sancio (jsancio) pushed a commit that referenced this pull request Sep 13, 2019
* Add Jenkinsfile that drives the Jenkins job.

* Start the downstream job.

* Minor updates of Jenkinsfile

* Set timeout to 4 hours.
* Only keep ce-trunk in the Kafka-Muckrake mapping

* Pass the same Kafka repo to the downstream test-cp job, and remove the
realJobPrefixes so that Jenkins can send out notifications.

* Fetch the Kafka branch name from the git repository.

* Use the env.CHANGE_BRANCH as the branch name for PR builds.

* Set the default muckrakeBranch to master.

* Pass PR-n as the branch name to the downstream build job.

* Trigger test-cp-downstream-builds-cekafka as the downstream job.

* Trim away the whitespaces from the kafkaRepo string.
Andrew Egelhofer (andrewegel) pushed a commit that referenced this pull request Nov 16, 2021
List of commits from kafka-broker-plugins:

* Include all transitive dependencies in assembly (#71)
* Add OAuth LoginCallbackHandler for the Kafka server (#72)
* CPKAFKA-1593: Multi-tenant authorizer for CCloud (#66)
* CPKAFKA-1593: Integration tests for multi-tenant authorizer for CCloud (#67)
* CAAS-1960: Implement Phase 3.1 Metrics (#76)
* CAAS-1960: Add authenticated connections and authentication rate metrics per tenant (#77)
* Bump Confluent to 5.2.0-SNAPSHOT, Kafka to 2.2.0-SNAPSHOT
* Topic config constraints (#70)
* Remove redundant import in MultiTenantRequestContext (#79)
* 4.1.x to 5.0.x (#78)
* 5.0.x to 5.1.x (#82)
* CPKAFKA-1408: Add tenant throughput and request quota plugin (#68)
* Improve topic policy checks (#81)
* CPKAFKA-1410: Partition assignor to balance partitions at tenant level (#73)
* CPKAFKA-1694: Add partition throughput percentiles for monitoring (#84)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants