[jira] [Created] (APEXMALHAR-2121) KafkaInputOperator emitTuple method should be able to emit more than just message

Priyanka Gugale created APEXMALHAR-2121: --- Summary: KafkaInputOperator emitTuple method should be able to emit more than just message Key: APEXMALHAR-2121 URL:

[jira] [Commented] (APEXCORE-222) Delegate Buffer Server purge to StreamingContainer

[ https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338980#comment-15338980 ] ASF GitHub Bot commented on APEXCORE-222: - Github user vrozov commented on a diff in the pull

[GitHub] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-core/pull/350#discussion_r67635187 --- Diff: engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java --- @@ -769,7 +769,11 @@ public void