python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
Serialize JSON String to AVRO Apache Beam KafkaIO
I have a JSON String that needs to be serialized to AVRO format so that I can publish that to a Kafka topic that has an Avro schema with schema validation on it. Below is what I have tried so far but ...
turingMan
Votes: 0
Answers: 1
Sink connector looking for topic -value schema instead of record name
Below is the Payload for JDBC Sink Connector
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
table.name.format=Subs_V1
behavior.on.null.values=ignore
connection.password=***********
topics...
Ragini Gupta
Votes: 0
Answers: 1
How to add an enum value to an AVRO schema in a FULL compatible way?
I have an enum in an AVRO schema like this :
{
"type": "record",
"name": "MySchema",
"namespace": "com.company",
"field...

singe3
Votes: 0
Answers: 3
Data type information lost when replication MySQL to PostgreSQL via Debezium
I need to replicate a MySQL database to a PostgreSQL database. I opted for:
Debezium connect
Avro format
confluent schema registry
kafka
The data is being replicated, however, I am losing some schem...
miro
Votes: 0
Answers: 1