我跟随这篇博客，制作一个关于kafka spring到目前为止的主题的消息。
我要传递的消息只是名称，现在我想通过这个主题进行流处理，并添加增量值作为ID以及名称并将其存储在OutputTopic上，现在，我想将数据存储到cassandra。
我在cassandra中的表结构如下:-
CREATE TABLE emp(
emp_id int PRIMARY KEY,
emp_name text,
)
输出主题上的数据应该是哪种格式，以便我可以轻松地将其存储在cassandra表上?
如何实现上述功能?
一旦你在Kafka主题上发布了数据，你就可以为Apache Cassandra, DataStax Enterprise和Astra DB使用DataStax Kafka连接器了。
连接器允许您将记录从Kafka主题保存到Cassandra表。它是开源的，所以可以免费使用。
这里有一个工作示例，其中包括一个Cassandra表模式，如何配置Kafka接收器连接器以及如何将主题映射到CQL表的详细信息。干杯!