File tree
109 files changed
+376
-373
lines changed- about
- configuration
- dump
- set
- setDrMsgCb
- setErrorCb
- setLogCb
- setOffsetCommitCb
- setRebalanceCb
- setStatsCb
- consumer
- __construct
- assign
- close
- commit
- commitAsync
- consume
- getAssignment
- getCommittedOffsets
- getMetadata
- getOffsetPositions
- getSubscription
- getTopicHandle
- offsetForTimes
- queryWatermarkOffsets
- subscribe
- unsubscribe
- functions
- kafka_err2name
- kafka_err2str
- kafka_get_err_descs
- kafka_offset_tail
- kafka_thread_cnt
- installation
- kafkaException
- __construct
- getErrorString
- isFatal
- isRetriable
- transactionRequiresAbort
- message
- getErrorString
- properties
- metadata
- broker
- getHost
- getId
- getPort
- metadata
- getBrokers
- getOrigBrokerId
- getOrigBrokerName
- getTopics
- partition
- getErrorCode
- getId
- getIsrs
- getLeader
- getReplicas
- topic
- getErrorCode
- getName
- getPartitions
- producer
- __construct
- abortTransaction
- beginTransaction
- commitTransaction
- flush
- getMetadata
- getTopicHandle
- initTransactions
- offsetForTimes
- poll
- purge
- queryWatermarkOffsets
- topicHandles
- about
- consumerTopic
- getName
- prodcuerTopic
- getName
- produce
- producev
- topicPartition
- __construct
- getOffset
- getPartition
- getTopicName
- setOffset
- setPartition
- setTopicName
- whats-new
- release-0.1.0
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
109 files changed
+376
-373
lines changedLines changed: 3 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
| 18 | + | |
19 | 19 |
| |
20 | 20 |
| |
21 |
| - | |
| 21 | + | |
| 22 | + |
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
19 |
| - | |
| 18 | + | |
| 19 | + | |
20 | 20 |
| |
21 | 21 |
| |
22 | 22 |
|
0 commit comments