justonedb kafka-sink-pg-json issues

justonedb / kafka-sink-pg-json

Kafka sink connector for streaming messages to PostgreSQL

MIT License

91 stars 31 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Required fixes

#24 kjell-van-straaten opened 2 years ago
0
Bump junit from 3.8.1 to 4.13.1

#23 dependabot[bot] opened 4 years ago
0
Failed to find any class that implements Connector and which name matches com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector

#22 jackeylhm opened 4 years ago
0
where are the .jar files?

#21 marcusbesjes opened 5 years ago
1
Can't seem to update offset.flush.interval.ms

#20 liambinnsconroy closed 6 years ago
0
No current assignment for partition

#19 abhishekmaheshwari86 opened 6 years ago
1
Even in synchronized modes, records can potentially be duplicated

#18 jdevalk2 opened 6 years ago
1
AbstractMethodError when running in Distributed Mode

#17 chen7515 opened 6 years ago
2
Error creating .start/.flush/.state/.drop functions

#16 servomac opened 7 years ago
1
java.lang.AbstractMethodError can't understand where to find a solution?

#15 wolandec opened 7 years ago
13
Confluent Config - Not recognizing class as Connector

#14 vijayvepa opened 7 years ago
1
Connect-Standalone ConfigDef error

#13 vijayvepa opened 7 years ago
1
Unable to start connector in standalone using the command

#12 suryakant54321 opened 7 years ago
2
kafka-connect sink not working for Oracle

#11 dgvj-work opened 7 years ago
0
怎样把完整的 json字符串，映射到数据库表中的一列(json类型)

#10 liangrui1988 opened 7 years ago
5
Connector Error

#9 rob-01 opened 7 years ago
3
When running Kafka Connect 3.1.1 with Kafk-sink-pg-json, my sink config is:{ "name": "bb1501_possink80", "config": { "connector.class": "com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector", "name": "bb1501_possink80", "topics": "mysql_people2", "db.host":"10.111.134.3", "db.database":"mytestdb", "db.username":"postgres", "db.table":"pgtable1", "db.schema":"$justone$kafka$connect$sink", "db.columns":"id,age,birthday,comment,name,sex", "db.delivery":"synchronized", "db.json.parse":"/@id,/@age,/@birthday,/@comment,/@name,/@sex", "db.buffer.size":"50" } }

#8 250690392 opened 7 years ago
0
Confluent 3.0

#7 decoursin closed 7 years ago
1
Feature requests

#6 cyclops23 opened 8 years ago
1
resume parition offset for kafka 0.10

#5 graphaelli closed 5 years ago
2
Avro Issue

#4 Oktaz opened 8 years ago
2
Json with \" fails

#3 killfill opened 8 years ago
1
Exception when running twice 'No current assignment for partition xxx-0'

#2 killfill opened 8 years ago
5
Fetch offset null is out of range, resetting offset

#1 duncanpauly closed 8 years ago
3