SnappyData параметр таблицы «темы» темы «темы»

Question

Я читал документацию (http://snappydatainc.github.io/snappydata/streamingWithSQL/) и хотел узнать, что означает параметр «: 01» после названия темы при работе с kafka. Используется ли это номер раздела или количество серверов потоков?

т.е. «темы„streamTopic: “

val sc = new SparkContext(new SparkConf().setAppName("example").setMaster("local[*]")) 
val snc = SnappyContext.getOrCreate(sc) 
var snsc = SnappyStreamingContext(snc, Seconds(1)) 

snsc.sql("create stream table streamTable (userId string, clickStreamLog string) " + 
    "using kafka_stream options (" + 
    "storagelevel 'MEMORY_AND_DISK_SER_2', " + 
    "rowConverter 'io.snappydata.app.streaming.KafkaStreamToRowsConverter', " + 
    "zkQuorum 'localhost:2181', " + 
    "groupId 'streamConsumer', " + 
    "topics 'streamTopic:01')") 

К сожалению, если это упоминается где-то, но я не мог найти его

Answer 1

Это должно быть только названия тем Спарк потоковое.. выяснит количество Кафок разделов и начать достаточно параллельные задачи для приема внутрь.

См другого примера here.