Files with the patch in knative-extensions/eventing-kafka-broker#2112
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
apiVersion: eventing.knative.dev/v1 | |
kind: Broker | |
metadata: | |
annotations: | |
eventing.knative.dev/broker.class: Kafka | |
name: <broker-name> | |
spec: | |
config: | |
apiVersion: v1 | |
kind: ConfigMap |
We can make this file beautiful and searchable if this error is corrected: Unclosed quoted field in line 5.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
"Take pointer to map in AsOptionalMap for consistency (#2460)","https://api.github.com/repos/knative/pkg/commits/3c4dec9b9f0eb95cef428ac875c2b9425ff9ac60","https://github.com/knative/pkg/commit/3c4dec9b9f0eb95cef428ac875c2b9425ff9ac60" | |
"Initialize prefix remapping map to avoid panic (#2453)","https://api.github.com/repos/knative/pkg/commits/ce6f2877cef94d5c91bafe2ce4acba52ee22c1fe","https://github.com/knative/pkg/commit/ce6f2877cef94d5c91bafe2ce4acba52ee22c1fe" | |
"Use t.Setenv instead of os.Setenv in tests (#2454)","https://api.github.com/repos/knative/pkg/commits/a850b9e047925436b4729c7f78ebc2f153bb3c51","https://github.com/knative/pkg/commit/a850b9e047925436b4729c7f78ebc2f153bb3c51" | |
"Allow overriding lease name for a reconciler (#2435)","https://api.github.com/repos/knative/pkg/commits/fe264173447bda1c4215a5ef7a010958ec5d7596","https://github.com/knative/pkg/commit/fe264173447bda1c4215a5ef7a010958ec5d7596" | |
"Bump golang.org/x/crypto (#2444)","https://api.github.com/repos/knative/pkg/commits/4c2331f26a93ca51f01 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# Copyright 2020 The Knative Authors | |
# | |
# Licensed under the Apache License, Version 2.0 (the "License"); | |
# you may not use this file except in compliance with the License. | |
# You may obtain a copy of the License at | |
# | |
# http://www.apache.org/licenses/LICENSE-2.0 | |
# | |
# Unless required by applicable law or agreed to in writing, software | |
# distributed under the License is distributed on an "AS IS" BASIS, |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"fmt" | |
"log" | |
"math" | |
"strings" | |
"github.com/google/uuid" | |
"google.golang.org/protobuf/encoding/protojson" |
Notes
- "sleep 900" means wait for jobs to be completed and pods to be running
#!/usr/bin/env bash
echo "Install v0.14.2"
kubectl apply -f https://github.com/knative/eventing/releases/download/v0.14.2/eventing-crds.yaml
kubectl apply -f https://github.com/knative/eventing/releases/download/v0.14.2/eventing-core.yaml
For the last three months, I've worked on an implementation of the Broker and Trigger API of Knative Eventing on top of Apache Kafka, alongside a lot of other dependent projects.
- https://github.com/knative-sandbox/eventing-kafka-broker repository hosts the final project.
- Documentation on how to use the project: https://knative.dev/docs/eventing/broker/kafka-broker/
- Project demo: https://youtu.be/XQeWOkpQcgw
We can make this file beautiful and searchable if this error is corrected: It looks like row 7 should actually have 7 columns, instead of 6. in line 6.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
"Benchmark","Mode","Threads","Samples","Score","Score Error (99.9%)","Unit" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull","thrpt",1,25,0.000509,0.000034,"ops/ns" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull:·gc.alloc.rate","thrpt",1,25,10947.724878,735.293659,"MB/sec" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull:·gc.alloc.rate.norm","thrpt",1,25,28199.501301,19.487457,"B/op" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull:·gc.churn.G1_Eden_Space","thrpt",1,25,11047.185150,750.941775,"MB/sec" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull:·gc.churn.G1_Eden_Space.norm","thrpt",1,25,28453.237249,155.883873,"B/op" | |
"dev.knative.eventing.kafka.broker.tests.core.ConfigUnmarshalling.benchmarkJsonUnmarshallingFull:·gc.churn.G1_Survivor_Space","thrpt",1,25,0.069631,0.0 |
{
"filter": {
"must": {
"time": {
"range": {
"gte": "<time>",
"lte": "<time>",
"lt": "<time>",
"gt": ""
package receiver
type ConsumerFunc func(request *nethttp.Request, binding.Message, []binding.TransformerFactory, nethttp.Header) error
type MessageReceiver struct {
consume ConsumerFunc
// logger and httpBindingsReceiver omitted
}