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

Vahid Hashemian commented on KAFKA-4572:
----------------------------------------

[~aravindk47]  I modified the log level in {{connect-log4j.properties}} to 
{{TRACE}} and ran the connect quickstart. This is part of what I got in 
{{stdout}} after running {{bin/connect-standalone.sh 
config/connect-standalone.properties config/connect-file-source.properties 
config/connect-file-sink.properties}}:

{code}
...
[2017-01-03 14:54:41,681] TRACE Read 8 bytes from test.txt 
(org.apache.kafka.connect.file.FileStreamSourceTask:130)
[2017-01-03 14:54:41,681] TRACE Read a line from test.txt 
(org.apache.kafka.connect.file.FileStreamSourceTask:144)
[2017-01-03 14:54:41,682] TRACE Read a line from test.txt 
(org.apache.kafka.connect.file.FileStreamSourceTask:144)
...
{code}

Please share more details if you are experiencing a different output. Thanks. 

> Kafka connect for windows is missing
> ------------------------------------
>
>                 Key: KAFKA-4572
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4572
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>    Affects Versions: 0.10.1.1
>         Environment: Windows.
>            Reporter: Aravind Krishnan
>            Assignee: Vahid Hashemian
>
> Unable to find the connect-standalone for windows. When created as below
> IF [%1] EQU [] (
>       echo USAGE: %0 connect-standalone.properties
>       EXIT /B 1
> )
> SetLocal
> rem Using pushd popd to set BASE_DIR to the absolute path
> pushd %~dp0..\..
> set BASE_DIR=%CD%
> popd
> rem Log4j settings
> IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
>       set 
> KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%BASE_DIR%/config/tools-log4j.properties
> )
> %~dp0kafka-run-class.bat org.apache.kafka.connect.cli.ConnectStandalone %*
> EndLocal
> Not able to see any of the below logs in FileStreamSourceTask
>   log.trace("Read {} bytes from {}", nread, logFilename());
> (OR)
>                             log.trace("Read a line from {}", logFilename());



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to