entityMap|0|type|LINK|mutability|MUTABLE|data|url|https://www.confluent.io/connector/kafka-connect-cassandra/|1|https://docs.lenses.io/2.0/connectors/sink/cassandra.html|2|https://docs.confluent.io/current/connect/devguide.html|3|https://docs.confluent.io/5.0.0-beta-20180702/connect/kafka-connect-cassandra/cassandra_sink_connector.html|4|https://medium.com/walmartlabs/getting-started-with-the-kafka-connect-cassandra-source-e6e06ec72e97|blocks|key|2qs1c|text|卡桑德拉水槽连接器在confluent+hub上可用，但卡桑德拉源连接器目前未由kafka.As提供，卡桑德拉源连接器由landoop提供。|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|b4llc|但是，Kafka也提供了创建自定义连接器的选项。|3r5ka|您需要扩展SourceConnector连接器类并覆盖它的方法。|style|CODE|eetha|public+class+CassandraSourceConnector+extends+SourceConnector+{


++++@Override
++++public+Class<?+extends+Task>+getTaskClass()+{
++++++return+ImplementationClasName.class;
++++}

++++@Override
++++public+void+start(Map<String,+String>+props)+{
+++++//+Properties
++++}

++++@Override
++++public+void+stop()+{
++++++//+Nothing+to+do+since+no+background+monitoring+is+required
++++}|code-block|syntax|javascript|baorq|您可以在https://docs.confluent.io/current/connect/devguide.html上找到完整的信息|hft0|在创建cassandra源连接器类之后，您还需要配置它，这可以像Cassandra+Sink+Connector一样完成。|2315v|到目前为止，Landoop+Cassandra+Source+connector仅适用于kafka+1.0和kafka+1.1。我建议您创建自己的连接器。您也可以访问此blog获取信息。|4fdno|希望，这对你有帮助。|u70o^0|A|D|0|1O|7|1|0|0|5|F|0|0|4|1J|2|0|W|O|3|0|2C|4|4|0|0^^$0|$1|$2|3|4|5|6|$7|8]]|9|$2|3|4|5|6|$7|A]]|B|$2|3|4|5|6|$7|C]]|D|$2|3|4|5|6|$7|E]]|F|$2|3|4|5|6|$7|G]]]|H|@$I|J|K|L|2|M|N|1C|O|@]|P|@$Q|1D|R|1E|I|1F]|$Q|1G|R|1H|I|1I]]|6|$]]|$I|S|K|T|2|M|N|1J|O|@]|P|@]|6|$]]|$I|U|K|V|2|M|N|1K|O|@$Q|1L|R|1M|W|X]]|P|@]|6|$]]|$I|Y|K|Z|2|10|N|1N|O|@]|P|@]|6|$11|12]]|$I|13|K|14|2|M|N|1O|O|@]|P|@$Q|1P|R|1Q|I|1R]]|6|$]]|$I|15|K|16|2|M|N|1S|O|@]|P|@$Q|1T|R|1U|I|1V]]|6|$]]|$I|17|K|18|2|M|N|1W|O|@]|P|@$Q|1X|R|1Y|I|1Z]]|6|$]]|$I|19|K|1A|2|M|N|20|O|@]|P|@]|6|$]]|$I|1B|K|-4|2|M|N|21|O|@]|P|@]|6|$]]]]

Cassandra Sink Connector is available at <a href="https://www.confluent.io/connector/kafka-connect-cassandra/" rel="nofollow noreferrer">confluent hub</a> but Cassandra Source connector is not provided by kafka.As of now,Cassandra Source connector is provided by the <a href="https://docs.lenses.io/2.0/connectors/sink/cassandra.html" rel="nofollow noreferrer">landoop</a>. 

However Kafka provides option to create custom connectors as well.

You need to extend the <code>SourceConnector</code> connector class and override its methods.

<pre><code>public class CassandraSourceConnector extends SourceConnector {


 @Override
 public Class&lt;? extends Task&gt; getTaskClass() {
 return ImplementationClasName.class;
 }

 @Override
 public void start(Map&lt;String, String&gt; props) {
 // Properties
 }

 @Override
 public void stop() {
 // Nothing to do since no background monitoring is required
 }
</code></pre>

You can find complete information at <a href="https://docs.confluent.io/current/connect/devguide.html" rel="nofollow noreferrer">https://docs.confluent.io/current/connect/devguide.html</a>

After creating the cassandra source connector class, you need to configure it also which can be done like <a href="https://docs.confluent.io/5.0.0-beta-20180702/connect/kafka-connect-cassandra/cassandra_sink_connector.html" rel="nofollow noreferrer">Cassandra Sink Connector</a>.

As of now,Landoop Cassandra Source connector is only available for kafka 1.0 and kafka 1.1. I would suggest you to create your own connector. You can also visited this <a href="https://medium.com/walmartlabs/getting-started-with-the-kafka-connect-cassandra-source-e6e06ec72e97" rel="nofollow noreferrer">blog</a> for information.

Hope,it is helpful to you.

entityMap|0|type|LINK|mutability|MUTABLE|data|url|https://docs.lenses.io/connectors/source/cassandra.html|1|https://medium.com/walmartlabs/getting-started-with-the-kafka-connect-cassandra-source-e6e06ec72e97|blocks|key|8oeq4|text|若要从外部系统获取数据到Kafka，建议使用Kafka+Connect。Kafka+Connect是一个框架，提供了一种在Apache+Kafka和其他数据系统之间传输数据的可扩展且可靠的方式。|unstyled|depth|inlineStyleRanges|entityRanges|56m22|有两种主要类型的sink连接器，source和Kafka连接器。源连接器将数据从外部系统输送到Kafka。接收器连接器通过管道将数据从Kafka输出到外部系统。|offset|length|style|CODE|7fjqh|为了将数据从Cassandra生成到Kafka，您需要找到一个Cassandra+Source连接器。最流行的是Landoop提供的Cassandra+Source连接器，作为镜头的一部分，可以是found+here。您将使用KCQL+(不要与KSQL混淆)来编写连接器查询，以便从Cassandra获取所需的信息。|5s1a2|我推荐你看看这篇博文，Getting+started+with+the+Kafka+Connect+Cassandra+Source，来设置所有的东西。|fie61^0|0|8|4|G|6|0|2Q|A|0|0|B|1J|1|0^^$0|$1|$2|3|4|5|6|$7|8]]|9|$2|3|4|5|6|$7|A]]]|B|@$C|D|E|F|2|G|H|V|I|@]|J|@]|6|$]]|$C|K|E|L|2|G|H|W|I|@$M|X|N|Y|O|P]|$M|Z|N|10|O|P]]|J|@]|6|$]]|$C|Q|E|R|2|G|H|11|I|@]|J|@$M|12|N|13|C|14]]|6|$]]|$C|S|E|T|2|G|H|15|I|@]|J|@$M|16|N|17|C|18]]|6|$]]|$C|U|E|-4|2|G|H|19|I|@]|J|@]|6|$]]]]

For getting data from external systems into Kafka, it's recommended to use Kafka Connect. Kafka Connect is a framework providing a scalable and reliable way of streaming data between Apache Kafka and other data systems. 

There are two main types of Kafka connectors, <code>source</code> and <code>sink</code> connectors. Source connectors pipe data into Kafka from an external system. Sink connectors pipe data out of Kafka and into an external system.

For producing data from Cassandra into Kafka, you'd want to find a Cassandra Source connector. The most popular one is the Cassandra Source connector provided by Landoop, as a part of Lenses, which can be <a href="https://docs.lenses.io/connectors/source/cassandra.html" rel="nofollow noreferrer">found here</a>. You'll use KCQL (not to be confused with KSQL) to write your connector query to get the information you want out of Cassandra. 

I'd recommend taking a look at this blog post, <a href="https://medium.com/walmartlabs/getting-started-with-the-kafka-connect-cassandra-source-e6e06ec72e97" rel="nofollow noreferrer">Getting started with the Kafka Connect Cassandra Source</a>, to set everything up.

How to integrate cassandra as a producer of data in apache Kafka?

Any specific configuration on kafka config?

Cassandra as a datasource/producer in kafka

Cassandra

Kafka

 如何在apache Kafka中集成cassandra作为数据生产者？ 在kafka配置上有什么特别的配置吗？ 

问Cassandra作为kafka中的数据源/生产者
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Cassandra作为kafka中的数据源/生产者EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Cassandra作为kafka中的数据源/生产者
EN