Good idea. I has modify the implementation:
/** Create time. **/
private final long createTime;
/** The time when marks the connection is idle. **/
private long IdleMarkTime;
/** The time when the last valid data was transmitted. **/
private long lastWorkTime;
/** Stat **/
private State stat;
/**
Hi yubiao
This is a good idea. But I have a question about the implementation.
I noticed that you use an int variable 'stat' to identify the stat of
connection. But a more general approach in Pulsar is to define a new stats
class that has an enum 'State' and some state-related method. And then ma
urfreespace commented on issue #83:
URL: https://github.com/apache/pulsar-site/issues/83#issuecomment-1146937235
resolved.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
T
urfreespace closed issue #83: Wrong position settings for GitHub Stars badge
URL: https://github.com/apache/pulsar-site/issues/83
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Hi Pulsar Community,I would like to start a VOTE on "Function add MANUAL delivery
semantics"(PIP-166).The proposal can be read at
https://github.com/apache/pulsar/issues/15560and the discussion thead is available
athttps://lists.apache.org/thread/4f2w1mqvhhs3mvccbcg2sk19b60xwkgfVoting will stay
Hi mentors,
Now it's time to log in to the OSSP system to review your project's
applications, then choose the best candidate *by June 11*.
Best,
Dianjin Wang
On Tue, May 10, 2022 at 9:53 AM Dianjin Wang wrote:
> Hi guys, thanks for your project ideas. I have helped submit your ideas to
> the
Hi Ran
I think you mean that: Producer/Consumer failed to establish a connection
when he tried to work again.
There are two places in the Broker configuration that limit the maximum
number of connections:
- Broker config : maxConnectionsLimitEnabled
- Broker config: maxConnectionsLimitPerIpEnable
