You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Diego Pettisani (Jira)" <ji...@apache.org> on 2023/11/04 21:33:00 UTC

[jira] [Comment Edited] (KAFKA-15783) Unable to set batchSize in log4j2 Kafka appender

    [ https://issues.apache.org/jira/browse/KAFKA-15783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782928#comment-17782928 ] 

Diego Pettisani edited comment on KAFKA-15783 at 11/4/23 9:32 PM:
------------------------------------------------------------------

Sorry,
only now I verified that we can modify{{ linger.ms}} and {{batch.size}} in this way:


{code:xml}
		<Kafka name="Kafka" topic="log-collector" syncSend="false"
			batchSize="8192">
			<PatternLayout
				pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" />
			<Property name="bootstrap.servers">localhost:9092</Property>
			<Property name="linger.ms">30</Property>
			<Property name="batch.size">16384</Property>
		</Kafka>
{code}

I try to close this issue.

Thanks at all


was (Author: diepet):
Sorry,
only now I verified that we can modify linger.ms and batch.size in this way:


{code:xml}
		<Kafka name="Kafka" topic="log-collector" syncSend="false"
			batchSize="8192">
			<PatternLayout
				pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" />
			<Property name="bootstrap.servers">localhost:9092</Property>
			<Property name="linger.ms">30</Property>
			<Property name="batch.size">16384</Property>
		</Kafka>
{code}

I try to close this issue.

Thanks at all

> Unable to set batchSize in log4j2 Kafka appender
> ------------------------------------------------
>
>                 Key: KAFKA-15783
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15783
>             Project: Kafka
>          Issue Type: Bug
>          Components: logging
>    Affects Versions: 3.6.0
>            Reporter: Diego Pettisani
>            Priority: Minor
>
> When I try to configure the batchSize of the Kafka log4j2 appender the application logs the following error:
> {noformat}
> ERROR StatusConsoleListener Kafka contains an invalid element or attribute "batchSize"
> {noformat}
> This is an example of configuration that fails:
> {code:xml}
> <?xml version="1.0" encoding="UTF-8"?>
> <Configuration status="WARN">
> 	<Appenders>
> 		<Console name="LogToConsole" target="SYSTEM_OUT">
> 			<PatternLayout
> 				pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" />
> 		</Console>
> 		<Kafka name="Kafka" topic="log-collector" syncSend="false"
> 			batchSize="8192">
> 			<PatternLayout
> 				pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" />
> 			<Property name="bootstrap.servers">localhost:9092</Property>
> 		</Kafka>
> 	</Appenders>
> 	<Loggers>
> 		<Root level="info">
> 			<AppenderRef ref="LogToConsole" />
> 			<AppenderRef ref="Kafka" />
> 		</Root>
> 		<Logger name="org.apache.kafka" level="WARN" /><!-- avoid recursive
> 		logging -->
> 	</Loggers>
> </Configuration>
> {code}
> Please note that other parameters like {{syncSend}} work fine.
> Could be possible that log4j2 expects this field:
> https://github.com/apache/kafka/blob/3.6.0/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java#L83C11-L83C11
> as a String for working fine?



--
This message was sent by Atlassian Jira
(v8.20.10#820010)