-----BEGIN PGP SIGNATURE-----
iQIzBAEBCAAdFiEEI8mthP+5zxXZZdDSO4miYXKq/OgFAl7O2oYACgkQO4miYXKq
/Ojx5Q//czy1UBZKiyL4FbYmYSC44wt2eQd30mc8+2cyEMLV2Zrefc7AXjSm3UJ9
iWtrUI6pGr9gQpCYDQWjq+bnntvn19abNpV5XZ888LMNhvezH8M+ksBNj5BLxsjb
Qhtp4GUVPezet27oocr4srdmeyYu0i9VsSD+vsON8bq+zMJpIKewWCY0EgWF/Yp5
bSG6MLbfG+odIj5sZtHWIjALmYBteH0VtG0lP3nNj1S6TdbB2QZcPxf6VhIDdhm8
9h/0x0nBHDbvtmucHGaw5nsVcTXwyd9hUchX/ly45jLzzk5zecfymI44oB3DfA4o
wKSOlkOcXwXQM/IiWg1FlskmExjsnYmSE2uHfO38oyIxNNlj6emg4eaNjEGq7nw1
5ERrv8uzyJ/E7oKFPPNOCZLBzrUJgzRmlejJ1k7yUQj1+mcxZhiLQjqtG6pMPxAJ
7YsVCTp38rwh+xr0CLvQ0BS+EL1coSf4iTP7iwpQmzOeYquCZiDjExZecIJ9dN5D
Hej9yY1NXkRhux6uRtGs+fw7Yfo6h2YULIiVrxhpc0PhbbE5A7vmv0pzoTSYqwpa
IF3jy8jEKaefEOJZAXOyl/tGA92Qn4yvPuVW6xXWBhY6U320l/BLrMrQkCT/MrnU
j0w+jgUM7JpEXZ920e0zkroS4utj57JB7g07BtJm5wWtMKLeU9k=
=aplH
-----END PGP SIGNATURE-----
Correct. The error implies that sending was not successful.
You can retry sending by calling `Producer#send()` again.
If you also increase the corresponding timeouts (`delivery.timeout.ms`).
-Matthias
On 5/26/20 10:27 AM, JOHN, BIBIN wrote:
>
> Team,
> Could you please help on my below query?
>
> -----Original Message-----
> From: JOHN, BIBIN <bj9306@att.com>
> Sent: Monday, May 25, 2020 11:48 PM
> To: users@kafka.apache.org
> Subject: Kafka Timeout Exception
>
> *** Security Advisory: This Message Originated Outside of AT&T ***.
> Reference http://cso.att.com/EmailSecurity/IDSP.html for more information.
>
> Team,
> What happens when producer gets below timeout exception? Is that error saying those records will be ignored and will not send to kafka?
>
>
> org.apache.kafka.common.errors.TimeoutException: Expiring 22 record(s) for topic1-1: 30215 ms has passed since batch creation plus linger time
> org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic1-14: 30073 ms has passed since batch creation plus linger time
>
iQIzBAEBCAAdFiEEI8mthP+5zxXZZdDSO4miYXKq/OgFAl7O2oYACgkQO4miYXKq
/Ojx5Q//czy1UBZKiyL4FbYmYSC44wt2eQd30mc8+2cyEMLV2Zrefc7AXjSm3UJ9
iWtrUI6pGr9gQpCYDQWjq+bnntvn19abNpV5XZ888LMNhvezH8M+ksBNj5BLxsjb
Qhtp4GUVPezet27oocr4srdmeyYu0i9VsSD+vsON8bq+zMJpIKewWCY0EgWF/Yp5
bSG6MLbfG+odIj5sZtHWIjALmYBteH0VtG0lP3nNj1S6TdbB2QZcPxf6VhIDdhm8
9h/0x0nBHDbvtmucHGaw5nsVcTXwyd9hUchX/ly45jLzzk5zecfymI44oB3DfA4o
wKSOlkOcXwXQM/IiWg1FlskmExjsnYmSE2uHfO38oyIxNNlj6emg4eaNjEGq7nw1
5ERrv8uzyJ/E7oKFPPNOCZLBzrUJgzRmlejJ1k7yUQj1+mcxZhiLQjqtG6pMPxAJ
7YsVCTp38rwh+xr0CLvQ0BS+EL1coSf4iTP7iwpQmzOeYquCZiDjExZecIJ9dN5D
Hej9yY1NXkRhux6uRtGs+fw7Yfo6h2YULIiVrxhpc0PhbbE5A7vmv0pzoTSYqwpa
IF3jy8jEKaefEOJZAXOyl/tGA92Qn4yvPuVW6xXWBhY6U320l/BLrMrQkCT/MrnU
j0w+jgUM7JpEXZ920e0zkroS4utj57JB7g07BtJm5wWtMKLeU9k=
=aplH
-----END PGP SIGNATURE-----
Correct. The error implies that sending was not successful.
You can retry sending by calling `Producer#send()` again.
If you also increase the corresponding timeouts (`delivery.timeout.ms`).
-Matthias
On 5/26/20 10:27 AM, JOHN, BIBIN wrote:
>
> Team,
> Could you please help on my below query?
>
> -----Original Message-----
> From: JOHN, BIBIN <bj9306@att.com>
> Sent: Monday, May 25, 2020 11:48 PM
> To: users@kafka.apache.org
> Subject: Kafka Timeout Exception
>
> *** Security Advisory: This Message Originated Outside of AT&T ***.
> Reference http://cso.att.com/EmailSecurity/IDSP.html for more information.
>
> Team,
> What happens when producer gets below timeout exception? Is that error saying those records will be ignored and will not send to kafka?
>
>
> org.apache.kafka.common.errors.TimeoutException: Expiring 22 record(s) for topic1-1: 30215 ms has passed since batch creation plus linger time
> org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic1-14: 30073 ms has passed since batch creation plus linger time
>
Comments
Post a Comment