Diego Pettisani created KAFKA-15783:
---------------------------------------
Summary: 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
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}} works 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)