issues
search
datastax
/
pulsar-sink
An Apache Pulsar® sink for transferring events/messages from Pulsar topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (DSE) tables.
Apache License 2.0
14
stars
10
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Upgrade Avro to 1.11.4 to address CVE-2024-47561
#67
nikhil-ctds
closed
1 month ago
0
deps: Update dependency to fix CVE-2023-5072 & CVE-2023-6378
#66
nikhil-ctds
closed
1 month ago
0
DO NOT MERGE: Update json and logback version
#65
nikhil-ctds
closed
2 months ago
0
trying to repro issue with null in udts
#64
dlg99
opened
2 months ago
0
DO NOT MERGE: Test CI
#63
nikhil-ctds
closed
2 months ago
0
fix: CI fails to install python 2.7
#62
dlg99
closed
2 months ago
0
fix: Error decoding/mapping Pulsar record with blob fields from CDC
#61
dlg99
closed
2 months ago
0
deps: Update dependency to fix CVE-2023-5072 & CVE-2023-6378
#60
nikhilerigila09
closed
1 month ago
2
Update Cassandra Java Client to 4.16.0 and DSBulk to 1.10.0, and Messaging Connectors Core to 1.0.15 in order to support Vector DataType
#59
eolivelli
closed
1 year ago
0
Upgrade org.json to fix CVE-45688
#58
nicoloboschi
closed
1 year ago
0
fix-links
#57
mendonk
closed
1 year ago
0
Update README.md for broken docs link
#56
cdbartholomew
opened
1 year ago
0
[feature] Map native Avro logical type that are generated by the an upstream CDC source
#54
aymkhalil
closed
1 year ago
0
Upgrade kafka clients to 3.4.0
#51
nicoloboschi
closed
1 year ago
0
Upgrade Netty and Jackson to get rid of CVEs
#50
nicoloboschi
closed
1 year ago
0
Use memory bound queue to receive records
#49
aymkhalil
closed
1 year ago
2
Add metrics to help troubleshooting sink limits
#48
aymkhalil
opened
1 year ago
0
Leverage a blocking queue with configurable `receiveQueueSize ` sink setting
#47
aymkhalil
closed
1 year ago
1
Upgrade jackson to 2.12.7.1
#46
nicoloboschi
closed
1 year ago
0
Add support for mapping nested fields from the record value
#45
nicoloboschi
opened
2 years ago
0
[avro][logical types] Add support for standard Avro logical types
#44
aymkhalil
opened
2 years ago
2
Support Avro's collection of GenericData$Record data types
#43
aymkhalil
closed
2 years ago
0
Support Cassandra CDC logical types (new option decodeCDCDataTypes)
#42
aymkhalil
closed
2 years ago
1
Add support for Collections types of Avro GenericData$Record
#41
aymkhalil
closed
2 years ago
0
Add support for logical AVRO types.
#40
aymkhalil
opened
2 years ago
1
Add nested complex types e2e tests
#39
aymkhalil
closed
2 years ago
0
[documentation] List the C* version supported by this sink
#38
aymkhalil
closed
2 years ago
1
Add tests to cover all C* collections types, nested collections & UDT with collections
#37
aymkhalil
closed
2 years ago
0
[ci] Add integration tests for cassandra 3.0 and DSE 5.1, 6.0, 6.7
#36
nicoloboschi
closed
2 years ago
0
Add support for Avro maps & lists
#35
aymkhalil
closed
2 years ago
3
Clean up the jenkins CI tests
#34
aymkhalil
closed
2 years ago
2
Support map/list CQ data types for Avro serialized pulsar messages
#33
aymkhalil
closed
2 years ago
2
Add PulsarStuct to JsonNode codec adapter
#32
aymkhalil
closed
2 years ago
1
Fix ClassCastException while sending null values for GenericRecord fields
#31
nicoloboschi
closed
2 years ago
0
Sending Pojo with Map to Sink gives Codec Missing Warning
#30
AndrewHogg
closed
2 years ago
1
Cannot Map a cql_decimal field coming from CDC for Cassandra
#29
eolivelli
closed
2 years ago
0
Upgrade org.json to 20220320
#28
nicoloboschi
closed
2 years ago
0
Run integration tests on Github CI
#27
nicoloboschi
closed
2 years ago
0
Add integration tests in github actions
#26
nicoloboschi
closed
2 years ago
0
[ci] add CI with JDK17
#25
nicoloboschi
closed
2 years ago
0
[security] Upgrade jackson-databind to get rid of CVE-2020-36518
#24
nicoloboschi
closed
2 years ago
0
Allow mapping headers/properties to non string columns
#23
jclu123
opened
2 years ago
0
Implement support for KeyValue schema
#22
eolivelli
closed
2 years ago
0
[test] flaky test CassandraSinkTaskBatchTest
#21
nicoloboschi
closed
2 years ago
0
Upgrade Pulsar dependency to 2.8.2
#20
nicoloboschi
closed
2 years ago
0
Create different distributions for Pulsar 2.7 and Pulsar 2.8+
#19
nicoloboschi
closed
2 years ago
1
RecordCassandraSinkTask fails from a localrun sink
#18
lhotari
closed
2 years ago
6
Add .nar artifact to the GitHub release binaries
#17
nicoloboschi
closed
2 years ago
1
Allow case insensitive mapping of columns and of UDT fields
#16
eolivelli
opened
3 years ago
0
sink not working with column with datatype 'timestamp' and python producer
#15
saveriogzz
opened
3 years ago
1
Next