[jira] [Updated] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue
[
https://issues.apache.org/jira/browse/KAFKA-7330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arikathota, Durga updated KAFKA-7330:
-
Attachment: disclaim.txt
image001.png
Any update on this issue please ?
Kind Regards,
Durga Prasad Arikathota
[ubslogo]
UBS WMA | Associate Director - Digital Advice Portal
1000, Harbor Blvd, Weehawken, NJ 07086
* (Skype) +1-201-352-2063
Visit our website at http://www.ubs.com
This message contains confidential information and is intended only
for the individual named. If you are not the named addressee you
should not disseminate, distribute or copy this e-mail. Please
notify the sender immediately by e-mail if you have received this
e-mail by mistake and delete this e-mail from your system.
E-mails are not encrypted and cannot be guaranteed to be secure or
error-free as information could be intercepted, corrupted, lost,
destroyed, arrive late or incomplete, or contain viruses. The sender
therefore does not accept liability for any errors or omissions in the
contents of this message which arise as a result of e-mail transmission.
If verification is required please request a hard-copy version. This
message is provided for informational purposes and should not be
construed as a solicitation or offer to buy or sell any securities
or related financial instruments.
UBS reserves the right to retain all messages. Messages are protected
and accessed only in legally justified cases.
For information on how UBS processes and keeps secure your personal
data, please visit our Privacy Notice at
https://www.ubs.com/global/en/legal/privacy.html
> Kakfa 0.10.2.1 producer close method issue
> --
>
> Key: KAFKA-7330
> URL: https://issues.apache.org/jira/browse/KAFKA-7330
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 0.10.2.1
> Environment: linux
>Reporter: vinay
>Priority: Major
> Attachments: disclaim.txt, image001.png
>
>
> We are creating new producer connections each time but in separate
> threads(pool of 40 and all threads will be used most of the time) and closing
> it when work in done. its a java process.
> Not always but sometimes close connection takes more than 10 seconds and
> observerd that particular message was never published.
> Could you please help.
>
> Properties prop = new Properties();
> {{prop.put("bootstarp.servers",-);}}
> prop.put("acks","all");
> //some ssl properties
> {\{--- }}
> //ends KafkaProducer
> connection = null;
> try {
> connection = new KafkaProducer(props); msg.setTopic(topic);
> {{msg.setDate(new Date());}}
> connection.send(msg);
> } catch() {
> } finally {
> connection.close();// sometimes it takes more than 10 secs and the above
> message was not send }}
> {{}}}
> Producer config :
> max.in.flight.requests.per.connection = 5
> acks= all
> batch.size = 16384
> linger.ms = 0
> max.block.ms = 6
> request.timeout.ms = 5000
> retries = 0
> ---
>
> Even i see below warning most of the times,
> Failed to send SSL Close message:
> java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected
> CLOSED, received OK. Will not send close message to peer.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue
[
https://issues.apache.org/jira/browse/KAFKA-7330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinay updated KAFKA-7330:
-
Description:
We are creating new producer connections each time but in separate threads(pool
of 40 and all threads will be used most of the time) and closing it when work
in done. its a java process.
Not always but sometimes close connection takes more than 10 seconds and
observerd that particular message was never published.
Could you please help.
Properties prop = new Properties();
{{prop.put("bootstarp.servers",-);}}
prop.put("acks","all");
//some ssl properties
{\{--- }}
//ends KafkaProducer
connection = null;
try {
connection = new KafkaProducer(props); msg.setTopic(topic);
{{msg.setDate(new Date());}}
connection.send(msg);
} catch() {
} finally {
connection.close();// sometimes it takes more than 10 secs and the above
message was not send }}
{{}}}
Producer config :
max.in.flight.requests.per.connection = 5
acks= all
batch.size = 16384
linger.ms = 0
max.block.ms = 6
request.timeout.ms = 5000
retries = 0
---
Even i see below warning most of the times,
Failed to send SSL Close message:
java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected
CLOSED, received OK. Will not send close message to peer.
was:
We are creating new producer connections each time but in separate threads(pool
of 40 and all threads will be used most of the time) and closing it when work
in done. its a java process.
Not always but sometimes close connection takes more than 10 seconds and
observerd that particular message was never published.
Could you please help.
{{Properties prop = new Properties(); }}
{{prop.put("bootstarp.servers",-);}}
{{prop.put("acks","all"); }}
{{//some ssl properties }}
{{--- }}
{{//ends KafkaProducer }}
{{connection = null; }}
{{try { }}
{{connection = new KafkaProducer(props); msg.setTopic(topic); }}
{{msg.setDate(new Date());}}
{{ connection.send(msg);}}
{{ } catch() {}}
{{ } finally { }}
{{connection.close();// sometimes it takes more than 10 secs and the above
message was not send }}
{{}}}
Producer config :
max.in.flight.requests.per.connection = 5
acks= all
batch.size = 16384
linger.ms = 0
max.block.ms = 6
request.timeout.ms = 5000
retries = 0
---
Even i see below warning most of the times,
Failed to send SSL Close message:
java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected
CLOSED, received OK. Will not send close message to peer.
> Kakfa 0.10.2.1 producer close method issue
> --
>
> Key: KAFKA-7330
> URL: https://issues.apache.org/jira/browse/KAFKA-7330
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 0.10.2.1
> Environment: linux
>Reporter: vinay
>Priority: Major
>
> We are creating new producer connections each time but in separate
> threads(pool of 40 and all threads will be used most of the time) and closing
> it when work in done. its a java process.
> Not always but sometimes close connection takes more than 10 seconds and
> observerd that particular message was never published.
> Could you please help.
>
> Properties prop = new Properties();
> {{prop.put("bootstarp.servers",-);}}
> prop.put("acks","all");
> //some ssl properties
> {\{--- }}
> //ends KafkaProducer
> connection = null;
> try {
> connection = new KafkaProducer(props); msg.setTopic(topic);
> {{msg.setDate(new Date());}}
> connection.send(msg);
> } catch() {
> } finally {
> connection.close();// sometimes it takes more than 10 secs and the above
> message was not send }}
> {{}}}
> Producer config :
> max.in.flight.requests.per.connection = 5
> acks= all
> batch.size = 16384
> linger.ms = 0
> max.block.ms = 6
> request.timeout.ms = 5000
> retries = 0
> ---
>
> Even i see below warning most of the times,
> Failed to send SSL Close message:
> java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected
> CLOSED, received OK. Will not send close message to peer.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
