Sachin Mittal

No. I have not changed the parser to process `TOUNIXTIMESTAMP` rather I have modified https://github.com/lensesio/stream-reactor/blob/master/kafka-connect-cassandra/src/main/scala/com/datamountaineer/streamreactor/connect/cassandra/source/CassandraTableReader.scala to use `row.getTimestamp(d.getName).getTime` if the field is of type ` DataType.timestamp`. Since in my case...

I have created a PR https://github.com/lensesio/stream-reactor/pull/680/. However this should not be merged the way it stands. I need to see how best to make this generic. If we add configuration...

I checked and right now I don't see any test case written for `CassandraTableReader`. Actually I have not worked on this since almost beginning of the year. As per comment:...

> We need to add tests to this change I have updated the test cases to `org.apache.beam.sdk.io.aws2.kinesis.WatermarkPolicyTest`. The essence of this PR is to get the current timestamp of the...

I am also facing the same issue when building from source. Is there any update on this ?