tuplejump/kafka-connect-cassandra

Fix config of connection ProtocolOptions.Compression setting.

helena opened this issue 9 years ago · 0 comments

helena commented 9 years ago

Since we are doing ProtocolOptions.Compression.valueOf(s) in https://github.com/tuplejump/kafka-connect-cassandra/blob/DB-53/src/main/scala/com/tuplejump/kafka/connect/cassandra/CassandraCluster.scala#L213 , the possible values should be snappy or lz4 or ``(empty)