saabeilin / kafkian Goto Github PK
View Code? Open in Web Editor NEWAn opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka
License: Apache License 2.0
An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka
License: Apache License 2.0
I know this is a silly question, but I don't know how to do that.
I try to check if message is None, but the consumer just stops consuming if there is no update, and message is the last message.
Could you please tell me how to do that?
for message in consumer: if message is not None: consumer.commit() else: consumer._close() break
Would be great to send [some] stats via statsd/dd-statsd. For example, backport from https://github.com/fyndiq/confluent_kafka_helpers/ - @simonwahlgren ?
What is the way to instantiate user
in the README example? It gives error:
$ python3 produce.py
Traceback (most recent call last):
File "produce.py", line 48, in <module>
user.uuid,
NameError: name 'user' is not defined
I really love this module, but would love the ability to disable logging. There are times when I would rather not have message contents in our Kibana logs, plus the other output puts unnecessary noise in the logs. I love the logging during development, however.
According to the following java code,
https://github.com/confluentinc/schema-registry/blob/master/avro-serializer/src/main/java/io/confluent/kafka/serializers/subject/TopicNameStrategy.java
I think,
RecordNameStrategy
, a subject must be the <fully-qulified avro recordName>
.TopicRecordNameStrategy
, a subject must be the <topicName>
-<fully-qulified avro recordName>
.But,
https://github.com/saabeilin/kafkian/blob/master/kafkian/serde/serialization.py#L48
all strategy has -key
or -value
suffix (subject += '-key' if is_key else '-value'
). These suffix should be applied only on TopicNameStrategy.
Anyway, I feel confluent-kafka-python is not user-friendly and does not support Subject Name Strategy well.
Thank you for your nice library!
i want to upload the kafka message to bigquery , for that i need schema of the object, or directly pass avro object to biquery because avro object contain schema itself
for msg in consumer:
msg.schema
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.