Comments (2)
Hello @mostafa ,
Thanks for the quick reply. I believe I had tried that approach, in any case, I just tried it again, and it fails for the same reason (panic because of the nil pointer). Debugging through the code, the error message I get is the following (same as before):
Union item 1 ought to be valid Avro type: unknown type name: "test.ProductCreated"
Given the goavro question you referred to is > 5 years old and hasn't been addressed yet, I guess chances to see it addressed are not that high. In any case, we have worked around the problem, but wanted to see if there was a way to fix it.
Thanks!
from xk6-kafka.
Hey @ehardy,
This seems to be a limitation of the goavro library, as raised here, yet I suppose you can make it work using a combination of the schema subject and the data, which is roughly like this, or something along the same lines:
const value = registry.serialize({
data: { "test.ProductCreated": {
id,
productName: 'test',
},
},
schema: schema,
schemaType: SCHEMA_TYPE_AVRO,
});
from xk6-kafka.
Related Issues (20)
- Request to add authentication through oauth bearer token HOT 1
- Unable to use relative path for the below script for parameters clientCertPem, clientKeyPem, serverCaPem HOT 4
- tls: failed to verify certificate: x509: certificate signed by unknown authority 0x14001158810}) HOT 3
- ERRO[0004] GoError: Failed to create schema., HOT 2
- Does xk6 support to get secrets from azure keyvault HOT 1
- ERRO[0002] Failed to get controller., OriginalError: %!w(*errors.errorString=&{EOF}) HOT 15
- ERRO[0002] GoError: Failed to decode JKS file: /test/833/truststore.jks, OriginalError: %!w(*errors.errorString=&{got invalid magic}) running at github.com/grafana/xk6-kafka.(*Kafka).loadJKSFunction-fm (native) HOT 15
- invalid character 'd' after top-level value 3 HOT 3
- failed to dial: tls: failed to verify certificate: x509: certificate signed by unknown authority HOT 4
- 42201 Invalid schema HOT 2
- ERRO[0007] GoError: Failed to validate JSON against schema,
- Type Map not working with Avro schema HOT 3
- Is there a way to run a test for a set amount of time at a constant rate? HOT 1
- Send messages to a kafka topic at a constant rate HOT 5
- Webpack bundler xk6-kafka HOT 1
- Writer is not sending to the indicated partition HOT 3
- Producing msgpack messages with xk6-kafka HOT 2
- Autocomplete not working in Vscode HOT 2
- Kafka connection failure in K6 tests HOT 10
- Kafka Admin Client Support for xk6-kafka HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from xk6-kafka.