Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm
Precedence: bulk
Reply-To: jira@kafka.apache.org
Date: Sat, 9 Sep 2017 08:21:02 +0000 (UTC)
From: "Ryan Worsley (JIRA)" <jira@apache.org>
To: jira@kafka.apache.org
Message-ID: <JIRA.13099409.1504371329000.68385.1504945262362@Atlassian.JIRA>
In-Reply-To: <JIRA.13099409.1504371329000@Atlassian.JIRA>
References: <JIRA.13099409.1504371329000@Atlassian.JIRA> <JIRA.13099409.1504371329050@jira-lw-us.apache.org>
Subject: [jira] [Commented] (KAFKA-5825) Streams not processing when exactly
 once is set
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Sat, 09 Sep 2017 08:21:11 -0000


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

Ryan Worsley commented on KAFKA-5825:
-------------------------------------

Hi [~guozhang] did you use the SBT file to satisfy the dependencies?

I'll post the full server logs as soon as I can.

> Streams not processing when exactly once is set
> -----------------------------------------------
>
>                 Key: KAFKA-5825
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5825
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.11.0.0
>         Environment: EmbeddedKafka running on Windows.  Relevant files attached.
>            Reporter: Ryan Worsley
>         Attachments: build.sbt, log4j.properties, Tests.scala
>
>
> +Set-up+
> I'm using [EmbeddedKafka|https://github.com/manub/scalatest-embedded-kafka/] for ScalaTest.
> This spins up a single broker internally on a random port.
> I've written two tests - the first without transactions, the second with.  They're nearly identical apart from the config and the transactional semantics.  I've written the transactional version based on Neha's [blog|https://www.confluent.io/blog/exactly-once-semantics-are-possible-heres-how-apache-kafka-does-it/] which is the closest thing I could find to instructions.
> The tests wait until a single message is processed by the streams topology, they use this message to complete a promise that the test is waiting on.  Once the promise completes the test verifies the value of the promise as being the expected value of the message.
> +Observed behaviour+
> The first test passes fine, the second test times out, the stream processor never seems to read the transactional message.
> +Notes+
> I've attached my build.sbt, log4j.properties and my Tests.scala file in order to make it as easy as possible for someone to re-create.  I'm running on Windows and using Scala as this reflects my workplace.  I completely expect there to be some configuration issue that's causing this, but am unable to proceed at this time.
> Related information: https://github.com/manub/scalatest-embedded-kafka/issues/82


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)