[
https://issues.apache.org/jira/browse/KAFKA-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661403#comment-14661403
]
ASF GitHub Bot commented on KAFKA-2408:
---------------------------------------
GitHub user granders opened a pull request:
https://github.com/apache/kafka/pull/123
KAFKA-2408 ConsoleConsumerService direct log output to file
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/confluentinc/kafka KAFKA-2408
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/123.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #123
----
commit 521a84b6d529d7f97cbb0e4cd099efdc5b88fe13
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-07T01:36:26Z
Updated console consumer to directo log output directly to file rather than
stdout
commit 8f890441aa755e3d79886b9d72bb572d3aa16fbd
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-07T02:44:49Z
Added another lifecycle check. Wait for log file to exist before exmaning
contents.
commit af67e01bf0a114701117b069cfde0ba44a43c75c
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-07T06:08:55Z
Merged in upstream trunk
commit e67f55423b8da89ec8592fae314e59bd21e585ee
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-07T06:25:53Z
Changed incorrect license header
commit 66d6f4f2dc37e1d7f3dc348c1e4e2651a3fceaa1
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-08-07T06:40:38Z
lower -> uperrcase constants
----
> (new) system tests: ConsoleConsumerService occasionally fails to register
> consumed message
> ------------------------------------------------------------------------------------------
>
> Key: KAFKA-2408
> URL: https://issues.apache.org/jira/browse/KAFKA-2408
> Project: Kafka
> Issue Type: Bug
> Reporter: Geoffrey Anderson
> Assignee: Geoffrey Anderson
> Fix For: 0.8.3
>
>
> There have been a few spurious failures in ReplicationTest.test_hard_bounce,
> where it was reported that a few of the acked messages were not consumed.
> Checking the logs, however, it is clear that they were consumed, but
> ConsoleConsumerService failed to parse.
> Lines causing parsing failure looks something like:
> 779725[2015-08-03 07:25:47,757] ERROR
> [ConsumerFetcherThread-console-consumer-78957_ip-172-31-5-20-1438586715191-249db71c-0-1],
> Error for partition [test_topic,0] to broker 1:class
> kafka.common.NotLeaderForPartitionException
> (kafka.consumer.ConsumerFetcherThread)
> (i.e. the consumed message, and a log message appear on the same line)
> ConsoleConsumerService simply tries to strip each line of whitespace and
> parse as an integer, which will clearly fail in this case.
> Solution should either redirect stderr elsewhere or update parsing to handle
> this.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
