org.apache.pulsar.client.impl

Class PartitionedProducerImpl<T>

java.lang.Object

org.apache.pulsar.client.impl.ProducerBase<T>

org.apache.pulsar.client.impl.PartitionedProducerImpl<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Producer<T>

public class PartitionedProducerImpl<T>
extends ProducerBase<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected PulsarClientImpl	client
protected String	topic

Fields inherited from class org.apache.pulsar.client.impl.ProducerBase

conf, interceptors, producerCreatedFuture, schema

Constructor Summary

Constructors

Constructor and Description
PartitionedProducerImpl(PulsarClientImpl client, String topic, ProducerConfigurationData conf, int numPartitions, CompletableFuture<Producer<T>> producerCreatedFuture, org.apache.pulsar.client.api.Schema<T> schema, ProducerInterceptors<T> interceptors)

Method Summary

Modifier and Type	Method and Description
protected boolean	changeToReadyState()
CompletableFuture<Void>	closeAsync() Close the producer and releases resources allocated.
CompletableFuture<Void>	flushAsync() Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
protected org.apache.pulsar.client.impl.HandlerState.State	getAndUpdateState(UnaryOperator<org.apache.pulsar.client.impl.HandlerState.State> updater)
PulsarClientImpl	getClient()
long	getLastSequenceId() Get the last sequence id that was published by this producer.
String	getProducerName()
List<ProducerImpl<T>>	getProducers()
protected org.apache.pulsar.client.impl.HandlerState.State	getState()
ProducerStatsRecorderImpl	getStats() Get statistics for the producer numMsgsSent : Number of messages sent in the current interval numBytesSent : Number of bytes sent in the current interval numSendFailed : Number of messages failed to send in the current interval numAcksReceived : Number of acks received in the current interval totalMsgsSent : Total number of messages sent totalBytesSent : Total number of bytes sent totalSendFailed : Total number of messages failed to send totalAcksReceived: Total number of acks received
boolean	isConnected()
protected void	setState(org.apache.pulsar.client.impl.HandlerState.State s)

Methods inherited from class org.apache.pulsar.client.impl.ProducerBase

beforeSend, close, flush, getConfiguration, getTopic, newMessage, onSendAcknowledgement, producerCreatedFuture, send, send, sendAsync, sendAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

client

protected final PulsarClientImpl client

topic

protected final String topic

Constructor Detail

PartitionedProducerImpl

public PartitionedProducerImpl(PulsarClientImpl client,
                               String topic,
                               ProducerConfigurationData conf,
                               int numPartitions,
                               CompletableFuture<Producer<T>> producerCreatedFuture,
                               org.apache.pulsar.client.api.Schema<T> schema,
                               ProducerInterceptors<T> interceptors)

Method Detail

getProducerName

public String getProducerName()

Returns:

the producer name which could have been assigned by the system or specified by the client

getLastSequenceId

public long getLastSequenceId()

Description copied from interface: Producer

Get the last sequence id that was published by this producer.

This represent either the automatically assigned or custom sequence id (set on the MessageBuilder) that was published and acknowledged by the broker.

After recreating a producer with the same producer name, this will return the last message that was published in the previous producer session, or -1 if there no message was ever published.

Returns:

the last sequence id published by this producer

flushAsync

public CompletableFuture<Void> flushAsync()

Description copied from interface: Producer

Flush all the messages buffered in the client and wait until all messages have been successfully persisted.

Returns:

a future that can be used to track when all the messages have been safely persisted.

See Also:

Producer.flush()

isConnected

public boolean isConnected()

Returns:

Whether the producer is connected to the broker

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: Producer

Close the producer and releases resources allocated. No more writes will be accepted from this producer. Waits until all pending write request are persisted. In case of errors, pending writes will not be retried.

Specified by:

closeAsync in interface Producer<T>

Specified by:

closeAsync in class ProducerBase<T>

Returns:

a future that can used to track when the producer has been closed

getStats

public ProducerStatsRecorderImpl getStats()

Description copied from interface: Producer

Get statistics for the producer

• numMsgsSent : Number of messages sent in the current interval
• numBytesSent : Number of bytes sent in the current interval
• numSendFailed : Number of messages failed to send in the current interval
• numAcksReceived : Number of acks received in the current interval
• totalMsgsSent : Total number of messages sent
• totalBytesSent : Total number of bytes sent
• totalSendFailed : Total number of messages failed to send
• totalAcksReceived: Total number of acks received

Returns:

statistic for the producer or null if ProducerStatsRecorderImpl is disabled.

getProducers

public List<ProducerImpl<T>> getProducers()

changeToReadyState

protected boolean changeToReadyState()

getState

protected org.apache.pulsar.client.impl.HandlerState.State getState()

setState

protected void setState(org.apache.pulsar.client.impl.HandlerState.State s)

getAndUpdateState

protected org.apache.pulsar.client.impl.HandlerState.State getAndUpdateState(UnaryOperator<org.apache.pulsar.client.impl.HandlerState.State> updater)

getClient

public PulsarClientImpl getClient()