public interface  io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent extends java.lang.Object implements io.fabric.kubernetes.api.builder.Fluent
{
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addToBootstrapServers(java.lang.Integer, java.lang.String);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent setToBootstrapServers(java.lang.Integer, java.lang.String);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addToBootstrapServers(java.lang.String[]);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addAllToBootstrapServers(java.util.Collection);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent removeFromBootstrapServers(java.lang.String[]);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent removeAllFromBootstrapServers(java.util.Collection);
public abstract java.util.List getBootstrapServers();
public abstract java.lang.String getBootstrapServer(java.lang.Integer);
public abstract java.lang.String getFirstBootstrapServer();
public abstract java.lang.String getLastBootstrapServer();
public abstract java.lang.String getMatchingBootstrapServer(java.util.function.Predicate);
public abstract java.lang.Boolean hasMatchingBootstrapServer(java.util.function.Predicate);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withBootstrapServers(java.util.List);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withBootstrapServers(java.lang.String[]);
public abstract java.lang.Boolean hasBootstrapServers();
public abstract io.fabric.knative.internal.pkg.apis.duck.v.CloudEventOverrides getCeOverrides();
public abstract io.fabric.knative.internal.pkg.apis.duck.v.CloudEventOverrides buildCeOverrides();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withCeOverrides(io.fabric.knative.internal.pkg.apis.duck.v.CloudEventOverrides);
public abstract java.lang.Boolean hasCeOverrides();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$CeOverridesNested withNewCeOverrides();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$CeOverridesNested withNewCeOverridesLike(io.fabric.knative.internal.pkg.apis.duck.v.CloudEventOverrides);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$CeOverridesNested editCeOverrides();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$CeOverridesNested editOrNewCeOverrides();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$CeOverridesNested editOrNewCeOverridesLike(io.fabric.knative.internal.pkg.apis.duck.v.CloudEventOverrides);
public abstract java.lang.String getConsumerGroup();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withConsumerGroup(java.lang.String);
public abstract java.lang.Boolean hasConsumerGroup();
public abstract java.lang.Integer getConsumers();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withConsumers(java.lang.Integer);
public abstract java.lang.Boolean hasConsumers();
public abstract java.lang.String getInitialOffset();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withInitialOffset(java.lang.String);
public abstract java.lang.Boolean hasInitialOffset();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaNetSpec getNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaNetSpec buildNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withNet(io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaNetSpec);
public abstract java.lang.Boolean hasNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$NetNested withNewNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$NetNested withNewNetLike(io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaNetSpec);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$NetNested editNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$NetNested editOrNewNet();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$NetNested editOrNewNetLike(io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaNetSpec);
public abstract io.fabric.knative.internal.pkg.apis.duck.v.Destination getSink();
public abstract io.fabric.knative.internal.pkg.apis.duck.v.Destination buildSink();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withSink(io.fabric.knative.internal.pkg.apis.duck.v.Destination);
public abstract java.lang.Boolean hasSink();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$SinkNested withNewSink();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$SinkNested withNewSinkLike(io.fabric.knative.internal.pkg.apis.duck.v.Destination);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$SinkNested editSink();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$SinkNested editOrNewSink();
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent$SinkNested editOrNewSinkLike(io.fabric.knative.internal.pkg.apis.duck.v.Destination);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addToTopics(java.lang.Integer, java.lang.String);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent setToTopics(java.lang.Integer, java.lang.String);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addToTopics(java.lang.String[]);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent addAllToTopics(java.util.Collection);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent removeFromTopics(java.lang.String[]);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent removeAllFromTopics(java.util.Collection);
public abstract java.util.List getTopics();
public abstract java.lang.String getTopic(java.lang.Integer);
public abstract java.lang.String getFirstTopic();
public abstract java.lang.String getLastTopic();
public abstract java.lang.String getMatchingTopic(java.util.function.Predicate);
public abstract java.lang.Boolean hasMatchingTopic(java.util.function.Predicate);
public abstract io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withTopics(java.util.List);
public abstract transient io.fabric.knative.eventing.contrib.kafka.v1beta.KafkaSourceSpecFluent withTopics(java.lang.String[]);
public abstract java.lang.Boolean hasTopics();
}