Code

Feature/kafka#510

Code

Merged

winlinvip merged 46 commits intodevelopossrs/srs:developfrom feature/kafkaossrs/srs:feature/kafkaCopy head branch name to clipboardOct 23, 2015

+3,890-1,416

Commits

Commits on Oct 23, 2015

• refine comments for api key

  winlinvip

  committed
  ca73534

  Copy full SHA for ca73534

• use system utility for string finds

  winlinvip

  committed
  d9f991e

  Copy full SHA for d9f991e

• use string for const char*

  winlinvip

  committed
  908365a

  Copy full SHA for 908365a

• use system utilities

  winlinvip

  committed
  69cc01b

  Copy full SHA for 69cc01b

• fix bug, use system utility

  winlinvip

  committed
  20fcfb3

  Copy full SHA for 20fcfb3

• use tcp client for raw connect.

  winlinvip

  committed
  a9bb606

  Copy full SHA for a9bb606

• use SrsTcpClient instead raw socket.

  winlinvip

  committed
  24b3899

  Copy full SHA for 24b3899

• use simple rtmp client for raw connect app

  winlinvip

  committed
  adb8f24

  Copy full SHA for adb8f24

• refine simple rtmp client for post flv stream.

  winlinvip

  committed
  a9ad7b2

  Copy full SHA for a9ad7b2

• refine code, support override vhost

  winlinvip

  committed
  e4c8529

  Copy full SHA for e4c8529

• refine code, use simple rtmp client.

  winlinvip

  committed
  bc27481

  Copy full SHA for bc27481

• refine code, use simple rtmp client.

  winlinvip

  committed
  12e0131

  Copy full SHA for 12e0131

• refine code, remove the rtmp recv/send macro, use one macro.

  winlinvip

  committed
  0f4cb8e

  Copy full SHA for 0f4cb8e

• refine forwarder code, use simple rtmp client.

  winlinvip

  committed
  ad9b377

  Copy full SHA for ad9b377

• refine mpegts code, use simple rtmp client

  winlinvip

  committed
  a08d8f8

  Copy full SHA for a08d8f8

• refine code, replace all rtmp connect by simple rtmp client.

  winlinvip

  committed
  a9fdb63

  Copy full SHA for a9fdb63

• connect to kafka and send metadata request.

  winlinvip

  committed
  8974fe2

  Copy full SHA for 8974fe2

• add graph comments for size of request and response.

  winlinvip

  committed
  8a4ec49

  Copy full SHA for 8a4ec49

• refine code for kakfa request/response, string/bytes.

  winlinvip

  committed
  45755fd

  Copy full SHA for 45755fd

• extract ISrsCodec for code and decode object.

  winlinvip

  committed
  9117e1e

  Copy full SHA for 9117e1e

• kafka encode and send packet.

  winlinvip

  committed
  3c64e4b

  Copy full SHA for 3c64e4b

• refine comments for kafka messages.

  winlinvip

  committed
  2e67eb8

  Copy full SHA for 2e67eb8

• for kafka, support correlation id cache.

  winlinvip

  committed
  6e5ed11

  Copy full SHA for 6e5ed11

• kafka rename message set to raw message set.

  winlinvip

  committed
  c486287

  Copy full SHA for c486287

• kafka refine array, to decode and create object.

  winlinvip

  committed
  493d282

  Copy full SHA for 493d282

• kafka recv and decode message.

  winlinvip

  committed
  a108fa8

  Copy full SHA for a108fa8

• kafka producer use async interface to request metadata.

  winlinvip

  committed
  7106934

  Copy full SHA for 7106934

• refs #1670: support decode the metadata response.

  winlinvip

  committed
  84b3981

  Copy full SHA for 84b3981

• add function to convert kafka array to vector

  winlinvip

  committed
  33a0153

  Copy full SHA for 33a0153

• rename ISrsCodec size to nb_bytes.

  winlinvip

  committed
  d013374

  Copy full SHA for d013374

• support show the summary of kafka metadata.

  winlinvip

  committed
  f0e39cc

  Copy full SHA for f0e39cc

• convert metadata to partitions

  winlinvip

  committed
  31a77a8

  Copy full SHA for 31a77a8

• kafka refine comments.

  winlinvip

  committed
  de41c1c

  Copy full SHA for de41c1c

• kafka send the accept message.

  winlinvip

  committed
  7013993

  Copy full SHA for 7013993

• kafka use topic and partition cache

  winlinvip

  committed
  61486a8

  Copy full SHA for 61486a8

• retry when metadata empty

  winlinvip

  committed
  531b658

  Copy full SHA for 531b658

• kafka use temp transport to fetch metadata.

  winlinvip

  committed
  22fa9a0

  Copy full SHA for 22fa9a0

• kakfa erase messages when wrote.

  winlinvip

  committed
  f9f5b56

  Copy full SHA for f9f5b56

• kafka refine code

  winlinvip

  committed
  7a0aaf5

  Copy full SHA for 7a0aaf5

• add producer api messages.

  winlinvip

  committed
  8e344f1

  Copy full SHA for 8e344f1

• kafka convert json to producer message.

  winlinvip

  committed
  76cd3f8

  Copy full SHA for 76cd3f8

• fix #467, support write log to kafka. 3.0.6

  winlinvip

  committed
  9a47390

  Copy full SHA for 9a47390

• refine kafka, simplify code.

  winlinvip

  committed
  7145187

  Copy full SHA for 7145187

• notify kafka when client close

  winlinvip

  committed
  d2ca51a

  Copy full SHA for d2ca51a

• refine code.

  winlinvip

  committed
  cbe4252

  Copy full SHA for cbe4252

• complete kafka

  winlinvip

  committed
  b8f2ba4

  Copy full SHA for b8f2ba4