public class Producer extends Object
| 构造器和说明 |
|---|
Producer() |
| 限定符和类型 | 方法和说明 |
|---|---|
String |
getCell() |
Long |
getCoordinatorEpoch()
coordinator_epoch
|
Long |
getCurrentTransactionStartOffset()
current_transaction_start_offset
|
String |
getId() |
String |
getInstanceId() |
Long |
getLastSequence()
last_sequence
|
Long |
getLastTimestamp()
last_timestamp
|
Long |
getPartition()
partition
|
Long |
getProducerEpoch()
producer_epoch
|
Long |
getProducerId()
producer_id
|
String |
getTopic()
topic
|
void |
setCell(String cell) |
void |
setCoordinatorEpoch(Long coordinatorEpoch)
coordinator_epoch
|
void |
setCurrentTransactionStartOffset(Long currentTransactionStartOffset)
current_transaction_start_offset
|
void |
setId(String id) |
void |
setInstanceId(String instanceId) |
void |
setLastSequence(Long lastSequence)
last_sequence
|
void |
setLastTimestamp(Long lastTimestamp)
last_timestamp
|
void |
setPartition(Long partition)
partition
|
void |
setProducerEpoch(Long producerEpoch)
producer_epoch
|
void |
setProducerId(Long producerId)
producer_id
|
void |
setTopic(String topic)
topic
|
public String getInstanceId()
public void setInstanceId(String instanceId)
public String getCell()
public void setCell(String cell)
public String getTopic()
public void setTopic(String topic)
public Long getPartition()
public void setPartition(Long partition)
public Long getProducerId()
public void setProducerId(Long producerId)
public Long getProducerEpoch()
public void setProducerEpoch(Long producerEpoch)
public Long getLastSequence()
public void setLastSequence(Long lastSequence)
public Long getLastTimestamp()
public void setLastTimestamp(Long lastTimestamp)
public Long getCoordinatorEpoch()
public void setCoordinatorEpoch(Long coordinatorEpoch)
public Long getCurrentTransactionStartOffset()
public void setCurrentTransactionStartOffset(Long currentTransactionStartOffset)
public String getId()
public void setId(String id)
Copyright © 2025. All Rights Reserved.