Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Feature/kafka #510

Merged
merged 46 commits into from
Oct 23, 2015
Merged

Feature/kafka #510

merged 46 commits into from
Oct 23, 2015

Conversation

winlinvip
Copy link
Member

for #467 write log to kafka cluster.

@winlinvip
refine comments for api key
ca73534
@winlinvip
use system utility for string finds
d9f991e
@winlinvip
use string for const char*
908365a
@winlinvip
use system utilities
69cc01b
@winlinvip
fix bug, use system utility
20fcfb3
@winlinvip
use tcp client for raw connect.
a9bb606
@winlinvip
use SrsTcpClient instead raw socket.
24b3899
@winlinvip
use simple rtmp client for raw connect app
adb8f24
@winlinvip
refine simple rtmp client for post flv stream.
a9ad7b2
@winlinvip
refine code, support override vhost
e4c8529
@winlinvip
refine code, use simple rtmp client.
bc27481
@winlinvip
refine code, use simple rtmp client.
12e0131
@winlinvip
refine code, remove the rtmp recv/send macro, use one macro.
0f4cb8e
@winlinvip
refine forwarder code, use simple rtmp client.
ad9b377
@winlinvip
refine mpegts code, use simple rtmp client
a08d8f8
@winlinvip
refine code, replace all rtmp connect by simple rtmp client.
a9fdb63
@winlinvip
connect to kafka and send metadata request.
8974fe2
@winlinvip
add graph comments for size of request and response.
8a4ec49
@winlinvip
refine code for kakfa request/response, string/bytes.
45755fd
@winlinvip
extract ISrsCodec for code and decode object.
9117e1e
@winlinvip
kafka encode and send packet.
3c64e4b
@winlinvip
refine comments for kafka messages.
2e67eb8
@winlinvip
for kafka, support correlation id cache.
6e5ed11
@winlinvip
kafka rename message set to raw message set.
c486287
@winlinvip
kafka refine array, to decode and create object.
493d282
@winlinvip
kafka recv and decode message.
a108fa8
@winlinvip
kafka producer use async interface to request metadata.
7106934
@winlinvip
refs #1670: support decode the metadata response.
84b3981
@winlinvip
add function to convert kafka array to vector
33a0153
@winlinvip
rename ISrsCodec size to nb_bytes.
d013374
winlinvip added a commit that referenced this pull request Oct 23, 2015
@winlinvip
Merge pull request #510 from simple-rtmp-server/feature/kafka
1cfd678 
Feature/kafka
@winlinvip winlinvip merged commit 1cfd678 into develop Oct 23, 2015
@winlinvip winlinvip deleted the feature/kafka branch October 23, 2015 06:45
@winlinvip
Copy link
Member Author

WIKI:
https://github.com/simple-rtmp-server/srs/wiki/v3_CN_Kafka
https://github.com/simple-rtmp-server/srs/wiki/v3_EN_Kafka

@winlinvip winlinvip added the EnglishNative This issue is conveyed exclusively in English. label Jul 29, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
EnglishNative This issue is conveyed exclusively in English.
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
1 participant
@winlinvip