Кафка подключить несколько тем в свойствах разъема приемника

Question

Я пытаюсь прочитать 2 темы Кафки, используя соединитель раковины Cassandra и вставить в 2 таблицы Cassandra. Как я могу сделать это?

Это мое connector.properties файл:

name=cassandra-sink-orders
connector.class=com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector
tasks.max=1
topics=topic1,topic2
connect.cassandra.kcql=INSERT INTO ks.table1 SELECT * FROM topic1;INSERT INTO ks.table2 SELECT * FROM topic2 
connect.cassandra.contact.points=localhost
connect.cassandra.port=9042
connect.cassandra.key.space=ks
connect.cassandra.contact.points=localhost
connect.cassandra.username=cassandra
connect.cassandra.password=cassandra

Я все делаю правильно? Это лучший способ сделать это, или я должен создать два отдельных разъема?

Answer 1

Если вы хотите использовать эти две темы для одного потребителя, это нормально и это правильная настройка. Лучший способ сделать это зависит от того, должны ли эти сообщения использоваться одним или двумя потребителями. Так что это зависит от вашей бизнес-логики.

В любом случае, если вы хотите использовать две темы через одного потребителя, который должен найти, поскольку потребитель может подписаться на несколько тем. Вы пробовали запустить этого потребителя? Работает?

Answer 2

Есть одна проблема с вашим конфигом. Вам нужно одно задание на тему-раздел. Так что, если ваши темы имеют один раздел, вам нужно tasks.max установить по крайней мере 2.

Я не вижу этого в документации Connect, что является позором