flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
/**
		 * Sets the topic from which the table is read.
		 *
		 * @param topic The topic from which the table is read.
		 * @return The builder.
		 */
Sets the topic from which the table is read.
@param topic The topic from which the table is read.
@return The builder.
Sets the topic from which the table is read . @param topic The topic from which the table is read . @return The builder .
public B forTopic(String topic) {
			Preconditions.checkNotNull(topic, "Topic must not be null.");
			Preconditions.checkArgument(this.topic == null, "Topic has already been set.");
			this.topic = topic;
			return builder();
		}
public B forTopic ( String topic ) { Preconditions . checkNotNull ( topic , "Topic must not be null." ) ; Preconditions . checkArgument ( this . topic == null , "Topic has already been set." ) ; this . topic = topic ; return builder ( ) ; }
Sets the topic from which the table is read.
Sets the topic from which the table is read .