Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Rename knative-sandbox to knative-extensions #3268

Merged
merged 2 commits into from
Aug 14, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions CONTRIBUTING.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,19 +14,19 @@ You need to install:
- [`ko`](https://github.com/google/ko) - (_required_)
- [`Go`](https://golang.org/) - (_required_)
- check
[go \<version\>](https://github.com/knative-sandbox/eventing-kafka-broker/blob/master/go.mod)
[go \<version\>](https://github.com/knative-extensions/eventing-kafka-broker/blob/master/go.mod)
for the required Go version used in this project
- [`Java`](https://www.java.com/en/) (we recommend an `openjdk` build) -
(_required_)
- check
[java.version](https://github.com/knative-sandbox/eventing-kafka-broker/blob/master/data-plane/pom.xml)
[java.version](https://github.com/knative-extensions/eventing-kafka-broker/blob/master/data-plane/pom.xml)
maven property for the required Java version used in this project
- [`protoc`](https://github.com/protocolbuffers/protobuf)
- To install protoc, you can follow https://grpc.io/docs/protoc-installation/
- `protoc-gen-go`
- To install `protoc-gen-go` run `go install google.golang.org/protobuf/cmd/protoc-gen-go@[version]`

_Note: See [`protoc` and `protoc-gen-go` current used versions](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/control-plane/pkg/contract/contract.pb.go#L3)_
_Note: See [`protoc` and `protoc-gen-go` current used versions](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/control-plane/pkg/contract/contract.pb.go#L3)_

Requirements signaled as "optional" are not required, but it's highly recommended having them installed. If a specific
version of a requirement is not explicitly defined above, any version will work during development.
Expand All @@ -44,7 +44,7 @@ cd ${GOPATH}/src/knative.dev
git clone [email protected]:knative/eventing.git # clone eventing repo
git clone [email protected]:${YOUR_GITHUB_USERNAME}/eventing-kafka-broker.git
cd eventing-kafka-broker
git remote add upstream https://github.com/knative-sandbox/eventing-kafka-broker.git
git remote add upstream https://github.com/knative-extensions/eventing-kafka-broker.git
git remote set-url --push upstream no_push
```

Expand Down
2 changes: 1 addition & 1 deletion INTERNALS.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ group to view it).
The **data-plane** is implemented in Java for leveraging the always up-to-date,
feature rich and tuned Kafka client. The **control-plane** is implemented in Go
following the
[Knative Kubernetes controllers](https://github.com/knative-sandbox/sample-controller).
[Knative Kubernetes controllers](https://github.com/knative-extensions/sample-controller).

- data-plane internals: [data-plane/README.md](data-plane/README.md).
<!--- TODO add control-plane internals --->
Expand Down
28 changes: 14 additions & 14 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,14 @@
</p>

<p align="center">
<a href="https://goreportcard.com/report/knative-sandbox/eventing-kafka-broker">
<img src="https://goreportcard.com/badge/knative-sandbox/eventing-kafka-broker" alt="Go-Report">
<a href="https://goreportcard.com/report/knative-extensions/eventing-kafka-broker">
<img src="https://goreportcard.com/badge/knative-extensions/eventing-kafka-broker" alt="Go-Report">
</a>
<a href="https://github.com/knative-sandbox/eventing-kafka-broker/releases">
<img src="https://img.shields.io/github/release-pre/knative-sandbox/eventing-kafka-broker.svg">
<a href="https://github.com/knative-extensions/eventing-kafka-broker/releases">
<img src="https://img.shields.io/github/release-pre/knative-extensions/eventing-kafka-broker.svg">
</a>
<a href="https://github.com/knative-sanbox/eventing-kafka-broker/blob/master/LICENSE">
<img src="https://img.shields.io/github/license/knative-sandbox/eventing-kafka-broker.svg">
<img src="https://img.shields.io/github/license/knative-extensions/eventing-kafka-broker.svg">
</a>
<a href="https://slack.cncf.io/">
<img src="https://img.shields.io/badge/slack-join_chat-white.svg?logo=slack&style=social">
Expand All @@ -27,28 +27,28 @@
</p>

<p align="center">
<a href="https://img.shields.io/github/downloads/knative-sandbox/eventing-kafka-broker/total">
<img src="https://img.shields.io/github/downloads/knative-sandbox/eventing-kafka-broker/total" alt="Downloads">
<a href="https://img.shields.io/github/downloads/knative-extensions/eventing-kafka-broker/total">
<img src="https://img.shields.io/github/downloads/knative-extensions/eventing-kafka-broker/total" alt="Downloads">
</a>
<a href="https://codecov.io/gh/knative-sandbox/eventing-kafka-broker">
<img src="https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/branch/master/graph/badge.svg" alt="Go-Report">
<a href="https://codecov.io/gh/knative-extensions/eventing-kafka-broker">
<img src="https://codecov.io/gh/knative-extensions/eventing-kafka-broker/branch/master/graph/badge.svg" alt="Go-Report">
</a>
<a href="https://testgrid.knative.dev/eventing-kafka-broker">
<img src="https://img.shields.io/badge/testgrid-eventing-informational?logo=data:image/x-icon;base64,AAABAAEAICAAAAEACACoCAAAFgAAACgAAAAgAAAAQAAAAAEACAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAALAAAAFQAAACoAAw0AAAAAVQAGGgAAAABgAAAAgAAKJgAAAACqAA0zAAATTAAAGmYAAB1zAAAmmQAAM8wAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAACgoKCgoKCAsQEBAQEBANDRAQEBAQEAsPEBAQEBAQAAAKCgoKCgoICxAQEBAQEA0NEBAQEBAQCw8QEBAQEBAAAAoKCgoKCggLEBAQEBAQDQ0QEBAQEBALDxAQEBAQEAAACgoKCgoKCAsQEBAQEBANDRAQEBAQEAsPEBAQEBAQAAAKCgoKCgoICxAQEBAQEA0NEBAQEBAQCw8QEBAQEBAAAAoKCgoKCggLEBAQEBAQDQ0QEBAQEBALDxAQEBAQEAAACAgICAgIBwkPDw8PDw8MDA8PDw8PDwkODw8PDw8PAAALCwsLCwsJBAsLCwsLCwYCAwMDAwMDAQkLCwsLCwsAABAQEBAQEA8LEBAQEBAQDQUKCgoKCgoDDxAQEBAQEAAAEBAQEBAQDwsQEBAQEBANBQoKCgoKCgMPEBAQEBAQAAAQEBAQEBAPCxAQEBAQEA0FCgoKCgoKAw8QEBAQEBAAABAQEBAQEA8LEBAQEBAQDQUKCgoKCgoDDxAQEBAQEAAAEBAQEBAQDwsQEBAQEBANBQoKCgoKCgMPEBAQEBAQAAAQEBAQEBAPCxAQEBAQEA0FCgoKCgoKAw8QEBAQEBAAAA0NDQ0NDQwGDQ0NDQ0NCwMFBQUFBQUCDA0NDQ0NDQAADQ0NDQ0NDAIFBQUFBQUDCw0NDQ0NDQYMDQ0NDQ0NAAAQEBAQEBAPAwoKCgoKCgUNEBAQEBAQCw8QEBAQEBAAABAQEBAQEA8DCgoKCgoKBQ0QEBAQEBALDxAQEBAQEAAAEBAQEBAQDwMKCgoKCgoFDRAQEBAQEAsPEBAQEBAQAAAQEBAQEBAPAwoKCgoKCgUNEBAQEBAQCw8QEBAQEBAAABAQEBAQEA8DCgoKCgoKBQ0QEBAQEBALDxAQEBAQEAAAEBAQEBAQDwMKCgoKCgoFDRAQEBAQEAsPEBAQEBAQAAALCwsLCwsJAQMDAwMDAwIGCwsLCwsLBAkLCwsLCwsAAA8PDw8PDw4JDw8PDw8PDAwPDw8PDw8JBwgICAgICAAAEBAQEBAQDwsQEBAQEBANDRAQEBAQEAsICgoKCgoKAAAQEBAQEBAPCxAQEBAQEA0NEBAQEBAQCwgKCgoKCgoAABAQEBAQEA8LEBAQEBAQDQ0QEBAQEBALCAoKCgoKCgAAEBAQEBAQDwsQEBAQEBANDRAQEBAQEAsICgoKCgoKAAAQEBAQEBAPCxAQEBAQEA0NEBAQEBAQCwgKCgoKCgoAABAQEBAQEA8LEBAQEBAQDQ0QEBAQEBALCAoKCgoKCgAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA">
</a>
<a href="https://github.com/issues?q=is%3Aopen+is%3Aissue+archived%3Afalse+org%3Aknative-sandbox+repo%3Aeventing-kafka-broker+label%3A%22help+wanted%22+%22+">
<img src="https://img.shields.io/github/issues/knative-sandbox/eventing-kafka-broker/help%20wanted.svg">
<a href="https://github.com/issues?q=is%3Aopen+is%3Aissue+archived%3Afalse+org%3Aknative-extensions+repo%3Aeventing-kafka-broker+label%3A%22help+wanted%22+%22+">
<img src="https://img.shields.io/github/issues/knative-extensions/eventing-kafka-broker/help%20wanted.svg">
</a>
</p>

<h5><p align="center"><b><i>If you’re using Knative or if you like the project, please <a href="https://github.com/knative-sandbox/eventing-kafka-broker/stargazers">★</a> this repository to show your support! 🤩</i></b></p></h5>
<h5><p align="center"><b><i>If you’re using Knative or if you like the project, please <a href="https://github.com/knative-extensions/eventing-kafka-broker/stargazers">★</a> this repository to show your support! 🤩</i></b></p></h5>

<p align="center">
<a href="https://knative.dev/docs/eventing/broker/kafka-broker/">Eventing Kafka Broker Docs</a> •
<a href="https://knative.dev/docs/eventing/sink/kafka-sink/">Eventing Kafka Sink Docs</a> •
<a href="docs/channel/README.md">Eventing Kafka Channel Docs</a> •
<a href="https://github.com/knative-sandbox/eventing-kafka-broker/blob/master/CONTRIBUTING.md">Contributing</a> •
<a href="https://github.com/issues?q=is%3Aopen+is%3Aissue+archived%3Afalse+org%3Aknative-sandbox+repo%3Aeventing-kafka-broker+label%3A%22help+wanted%22+%22+">Help Wanted Issues</a>
<a href="https://github.com/knative-extensions/eventing-kafka-broker/blob/master/CONTRIBUTING.md">Contributing</a> •
<a href="https://github.com/issues?q=is%3Aopen+is%3Aissue+archived%3Afalse+org%3Aknative-extensions+repo%3Aeventing-kafka-broker+label%3A%22help+wanted%22+%22+">Help Wanted Issues</a>
</p>

## Working Group
Expand Down
2 changes: 1 addition & 1 deletion control-plane/pkg/reconciler/broker/broker.go
Original file line number Diff line number Diff line change
Expand Up @@ -453,7 +453,7 @@ func (r *Reconciler) finalizeKind(ctx context.Context, broker *eventing.Broker)
func (r *Reconciler) deleteResourceFromContractConfigMap(ctx context.Context, logger *zap.Logger, broker *eventing.Broker) error {
// Get contract config map.
contractConfigMap, err := r.GetOrCreateDataPlaneConfigMap(ctx)
// Handles https://github.com/knative-sandbox/eventing-kafka-broker/issues/2893
// Handles https://github.com/knative-extensions/eventing-kafka-broker/issues/2893
// When the system namespace is deleted while we're running there is no point in
// trying to delete the resource from the ConfigMap since the entire ConfigMap
// is gone.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -326,7 +326,7 @@ func (r Reconciler) schedule(ctx context.Context, cg *kafkainternals.ConsumerGro

// Ensure Contract configmaps are created before scheduling to avoid having pending pods due to missing
// volumes.
// See https://github.com/knative-sandbox/eventing-kafka-broker/issues/2750#issuecomment-1304244017
// See https://github.com/knative-extensions/eventing-kafka-broker/issues/2750#issuecomment-1304244017
if err := r.ensureContractConfigmapsExist(ctx, statefulSetScheduler); err != nil {
return cg.MarkScheduleConsumerFailed("Schedule", err)
}
Expand Down
2 changes: 1 addition & 1 deletion control-plane/pkg/security/secret.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ const (
SaslScramSha256 = "SCRAM-SHA-256"
SaslScramSha512 = "SCRAM-SHA-512"

// Legacy Channel config to enable TLS, see https://github.com/knative-sandbox/eventing-kafka-broker/issues/2231
// Legacy Channel config to enable TLS, see https://github.com/knative-extensions/eventing-kafka-broker/issues/2231
SSLLegacyEnabled = "tls.enabled"
)

Expand Down
12 changes: 6 additions & 6 deletions docs/broker/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ The `kafka-controller` is kind of the heart of the Broker for Apache Kafkas cont
* `KafkaSource`s
* Update the status on `Broker` resources that have the `eventing.kantive.dev/broker.class: Kafka` annotation with the ingress address of the broker.

The `kafka-broker-brokers-triggers` configmap contains information about the resources in the [contract.proto](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/proto/contract.proto) schema. This makes it easily accessible to other components, such as those operating in the data plane.
The `kafka-broker-brokers-triggers` configmap contains information about the resources in the [contract.proto](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/proto/contract.proto) schema. This makes it easily accessible to other components, such as those operating in the data plane.

## Data Plane

Expand All @@ -32,8 +32,8 @@ The `kafka-broker-dispatcher` polls periodically Apache Kafka for new messages,

### Core Classes

* [FileWatcher](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java): The `FileWatcher`, listens for changes on the contract file (volume mounting the `kafka-broker-brokers-triggers` configmap) and sends events about updates to the (vertx) event bus.
* [ResourcesReconcilerMessageHandler](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/impl/ResourcesReconcilerMessageHandler.java): The `ResourcesReconcilerMessageHandler` listens for events from the `FileWatcher` on the event bus and triggers the `ResourcesReconciler` to reconcile the resource. It gets created from the receiver (`ReceiverVerticle`) and dispatcher (`ConsumerDeployerVerticle`) through some factories.
* [ResourcesReconciler](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/ResourcesReconciler.java): The `ResourcesReconciler` reconciles a resource based on the contract file.
* [IngressReconcilerListener](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/IngressReconcilerListener.java): The `IngressReconcilerListener` is setup by the receiver (`ReceiverVerticle`) to reconcile the ingresses of the resources.
* [EgressReconcilerListener](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/EgressReconcilerListener.java): The `EgressReconcilerListener` is setup by the dispatcher (`ConsumerDeployerVerticle`) to reconcile the egresses of the resources.
* [FileWatcher](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java): The `FileWatcher`, listens for changes on the contract file (volume mounting the `kafka-broker-brokers-triggers` configmap) and sends events about updates to the (vertx) event bus.
* [ResourcesReconcilerMessageHandler](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/impl/ResourcesReconcilerMessageHandler.java): The `ResourcesReconcilerMessageHandler` listens for events from the `FileWatcher` on the event bus and triggers the `ResourcesReconciler` to reconcile the resource. It gets created from the receiver (`ReceiverVerticle`) and dispatcher (`ConsumerDeployerVerticle`) through some factories.
* [ResourcesReconciler](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/ResourcesReconciler.java): The `ResourcesReconciler` reconciles a resource based on the contract file.
* [IngressReconcilerListener](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/IngressReconcilerListener.java): The `IngressReconcilerListener` is setup by the receiver (`ReceiverVerticle`) to reconcile the ingresses of the resources.
* [EgressReconcilerListener](https://github.com/knative-extensions/eventing-kafka-broker/blob/main/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/reconciler/EgressReconcilerListener.java): The `EgressReconcilerListener` is setup by the dispatcher (`ConsumerDeployerVerticle`) to reconcile the egresses of the resources.
2 changes: 1 addition & 1 deletion docs/broker/eventing-kafka-broker.svg
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Loading