Comments (4)
Hello @robertpcontreras-ts,
This feature is in development process. See #5
I'm planning to release this later today or tomorrow morning.
from laravel-kafka.
@robertpcontreras-ts released on v1.1.0 😄
from laravel-kafka.
We can deserialize a msg without knowing the scehma or topic: in FlixTech\AvroSerializer\Objects\RecordSerializer .
msg in kafka has already information about the schema so can we have this feature in this package? @mateusjunges
so after that we do not need
$registry->addBodySchemaMappingForTopic(
'test-topic',
new \Junges\Kafka\Message\KafkaAvroSchema('bodySchema' , 9 /* , AvroSchema $definition /)
);
$registry->addKeySchemaMappingForTopic(
'test-topic',
new \Junges\Kafka\Message\KafkaAvroSchema('keySchema' , 9 / , AvroSchema $definition */)
);
and it will decode based on message data.
from laravel-kafka.
@mateusjunges any update about above comment?
it's serious/
let me please explain a situation,
we create a command to consume a topic.
then it is consuming and waiting for next message, but meanwhile , producer will produce a new message base on a new version of avro schema, then when application take the next message, cannot decerialize it and throw the FlixTech\AvroSerializer\Objects\Exceptions\AvroDecodingException/app/vendor/flix-tech/avro-serde-php/src/Objects/Exceptions/Exceptions.php:42
Could not decode message. Binary Message (as Hex): "00
so if consumer could know the new message avro schema version and take it , it wouldn't happen.
from laravel-kafka.
Related Issues (20)
- Upstash Support - Producer not sending messages. HOT 3
- Wrong return type in Junges\Kafka\Config\Config->getCommit HOT 2
- Cannot Consume published messages in laravel 11 and php 8.3.6 HOT 15
- Issue consuming records from Avro topic HOT 1
- Cannot consume produced messages in v2.0 HOT 2
- What do we need to set for the `--consumer` flag. HOT 1
- Message consuming is still an issue in v2.1 HOT 10
- Encoded payloads: Is it possible with Avro Serializer to Save encoded messages in Kafka when sending it using AvroSerialize and doing the opposite when reading with Deserializer HOT 1
- Is there any support to Retry policies ? HOT 2
- [QUESTION] Possibility to describe topic / calculate read backlog HOT 1
- [Question/bug] Consuming Tombstones and send it to dlq throws $payload must be of type string, null given HOT 1
- cant send message HOT 8
- Error "Specified group generation id is not valid" during consumption HOT 3
- How to commit each message in withHandler HOT 1
- Missing messages HOT 2
- Customizable flush retried and timeout
- stopAfterLastMessage not working as expected. HOT 1
- Undefined constant "Junges\Kafka\RD_KAFKA_PARTITION_UA", HOT 2
- Consumer middlewares cannot be implemented at described HOT 4
- Support for php 7.4 and laravel 8 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 laravel-kafka.