-
Notifications
You must be signed in to change notification settings - Fork 0
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
Kafka cluster CRD spec was updated with Kraft field #529
Conversation
2804472
to
02d3399
Compare
pkg/models/errors.go
Outdated
@@ -33,6 +35,7 @@ var ( | |||
ErrTypeAssertion = errors.New("unable to assert type") | |||
ErrImmutableSchemaRegistry = errors.New("schema registry is immutable") | |||
ErrImmutableRestProxy = errors.New("rest proxy is immutable") | |||
ErrImmutableKraft = errors.New("Kraft is immutable") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Kraft -> kraft
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
pkg/models/errors.go
Outdated
@@ -20,6 +20,8 @@ import "errors" | |||
|
|||
var ( | |||
ErrZeroDataCentres = errors.New("cluster spec doesn't have data centres") | |||
ErrMoreThanOneKraft = errors.New("cluster spec spec does not support more than one Kraft") | |||
ErrMoreThanThreeControllerNodeCount = errors.New("Kraft does not support more than three controller nodes") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Kraft -> kraft
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
refactored
pkg/models/kafka_apiv2.go
Outdated
@@ -34,6 +34,7 @@ type KafkaCluster struct { | |||
DedicatedZookeeper []*DedicatedZookeeper `json:"dedicatedZookeeper"` | |||
DefaultNumberOfPartitions int `json:"defaultNumberOfPartitions"` | |||
DefaultReplicationFactor int `json:"defaultReplicationFactor"` | |||
Kraft []*Kraft `json:"kraft"` |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Kraft []*Kraft `json:"kraft"` | |
Kraft []*Kraft `json:"kraft,omitempty"` |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
refactored
62f9e21
to
ef36f0d
Compare
pkg/models/errors.go
Outdated
@@ -20,6 +20,8 @@ import "errors" | |||
|
|||
var ( | |||
ErrZeroDataCentres = errors.New("cluster spec doesn't have data centres") | |||
ErrMoreThanOneKraft = errors.New("cluster spec spec does not support more than one kraft") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
spec spec
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
refactored
ef36f0d
to
1e15396
Compare
No description provided.