Stack Overflow
Stack Overflow

Questions tagged [apicurio-registry]

12 questions
1
vote
1 answer

ksqlDB with Apicurio Registry

I’m trying to make ksqlDB work with Apicurio Registry (RedHat) and have had a few issues with compatibility with Debezium. So, Apicurio has 4 different APIs that can be used. The “official” and recommended api is called "/registry/v2" and it seems…
Propster
  • 19
  • 4
0
votes
1 answer

Apicurio registry client - enable logging of REST communication via OkHttpClient

I have a Spring Boot application which sends some message to Kafka. We use Apicurio registry provided by our customer to manage AVRO schema for message serialization. The application uses Apicurio registry client, namely the Maven artifact…
Tomáš Záluský
  • 10,735
  • 2
  • 36
  • 64
0
votes
0 answers

Internal and external hosts with Apicurio Registry UI and Keycloak

I'm using Keycloak (using Keycloak Operator 21.1.1) to enable authentication to the Apicurio Registry ui (apicurio/apicurio-registry-kafkasql:2.4.2.Final) inside my Kubernetes cluster. In addition to that, I'm using an nginx ingress to enable…
Dominik
  • 55
  • 1
  • 6
0
votes
0 answers

"artifactId cannot be null" error in Apicurio Registry's deserializer

I am trying to figure what Kafka record header format does Apicurio Registry's deserializer expect. My Avro Schema in Apicurio Registry I have an artifact with ID hm.motor-value. curl --location…
Hongbo Miao
  • 45,290
  • 60
  • 174
  • 267
0
votes
2 answers

How to use io.apicurio.registry.utils.converter.AvroConverter in Kafka Connect created by Strimzi?

I have a Kafka cluster deployed by Strimzi and Apicurio Registry for Kafka schema registry. I am hoping to use AvroConverter in the JDBC sink connector to sink data from Kafka to TimescaleDB. Here is my Kafka Connect Dockerfile: FROM…
Hongbo Miao
  • 45,290
  • 60
  • 174
  • 267
0
votes
0 answers

Error creating example ksqldb stream with avro

I am trying to follow this tutorial to make a ksqldb stream using avro (https://rmoff.net/2021/03/12/kafka-connect-jdbc-sink-deep-dive-working-with-primary-keys/). I try the first command: CREATE STREAM FOO_01 (COL1 INT, COL2 INT) WITH…
Jicaar
  • 1,044
  • 10
  • 26
0
votes
1 answer

How to push schema to Apicurio schema registry without any cdc event/records using Debezium

Usecase: I need my all schemas for all tables in sql database to be present in apicurio registry without having any cdc records in cdc tables using Debezium. Currently, schema is pushed to Apicurio for only those table on which CDC is enabled and if…
Roobal Jindal
  • 214
  • 2
  • 13
0
votes
0 answers

Apicurio-registry on kubernetes shows 404

I have "kubertinirize" a few images like the "Apicurio" which seems to work nice on Azure Kubernetes Cluster. Then when I hit the link http:///apis/registry/v2/search/artifacts?limit=10&order=asc&orderby=name Sometimes I get proper…
Stavros Koureas
  • 1,126
  • 12
  • 34
0
votes
0 answers

Running spring boot with apicurio registry gives javax.ws.rs.WebApplicationException: Not Found

I am developing an application which can validate json payload via apicurio registry. I am running apicurio in memory. I have created a artifact in apicurio registry with topicname-value. My version of apicurio is 2.3.1.final But when I produce…
user1834664
  • 443
  • 3
  • 12
  • 22
0
votes
0 answers

How to pass global id in kafka messages for apicurio registry integration

Hi I am developing an spring boot application with kafka and apicuro registry. I want to validate JSON messages which is being produced and consumed. I have setup the below configuration in my application spring.kafka.producer.bootstrap-servers:…
user1834664
  • 443
  • 3
  • 12
  • 22
0
votes
1 answer

KSQLDB Push Queries Fail to Deserialize Data - Schema Lookup Performed with Wrong Schema ID

I'm not certain what I could be missing. I have set up a Kafka broker server, with a Zookeeper and a distributed Kafka Connect. For schema management, I have set up an Apicurio Schema Registry instance I also have KSQLDB setup The following I can…
Felix Otoo
  • 109
  • 1
  • 3
0
votes
0 answers

Unable to register schame using Avro with Nested class

Whenever there is nested object in Avro class schema is not getting saved always get exception like org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler connect_1 | at…
G.Khandal
  • 44
  • 1
  • 3