[
https://issues.apache.org/jira/browse/BEAM-2852?focusedWorklogId=112256&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-112256
]
ASF GitHub Bot logged work on BEAM-2852:
----------------------------------------
Author: ASF GitHub Bot
Created on: 15/Jun/18 09:08
Start Date: 15/Jun/18 09:08
Worklog Time Spent: 10m
Work Description: asfgit closed pull request #460: [BEAM-2852] Update
Nexmark documentation with Kafka support
URL: https://github.com/apache/beam-site/pull/460
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/src/documentation/sdks/nexmark.md
b/src/documentation/sdks/nexmark.md
index d73943a4f..7abeb651b 100644
--- a/src/documentation/sdks/nexmark.md
+++ b/src/documentation/sdks/nexmark.md
@@ -138,11 +138,11 @@ When running via Gradle, the following two parameters
control the execution:
Test data is deterministically synthesized on demand. The test
data may be synthesized in the same pipeline as the query itself,
-or may be published to Pub/Sub.
+or may be published to Pub/Sub or Kafka.
The query results may be:
-* Published to Pub/Sub.
+* Published to Pub/Sub or Kafka.
* Written to text files as plain text.
* Written to text files using an Avro encoding.
* Sent to BigQuery.
@@ -205,6 +205,28 @@ Available suites are:
--manageResources=false --monitorJobs=true \
--sparkMaster=local \
-Dspark.ui.enabled=false -DSPARK_LOCAL_IP=localhost
-Dsun.io.serialization.extendedDebugInfo=true
+
+### Kafka source/sink configuration parameters
+
+Set Kafka host/ip (for example, "localhost:9092"):
+
+ --bootstrapServers=<kafka host/ip>
+
+Write results into Kafka topic:
+
+ --sinkType=KAFKA
+
+Set topic name which will be used for benchmark results:
+
+ --kafkaResultsTopic=<topic name>
+
+Write or/and read events into/from Kafka topic:
+
+ --sourceType=KAFKA
+
+Set topic name which will be used for benchmark events:
+
+ --kafkaTopic=<topic name>
## Current status
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 112256)
Time Spent: 6h 50m (was: 6h 40m)
> Add support for Kafka as source/sink on Nexmark
> -----------------------------------------------
>
> Key: BEAM-2852
> URL: https://issues.apache.org/jira/browse/BEAM-2852
> Project: Beam
> Issue Type: Improvement
> Components: testing
> Reporter: Ismaël Mejía
> Assignee: Alexey Romanenko
> Priority: Minor
> Labels: newbie, nexmark, starter
> Fix For: 2.5.0
>
> Time Spent: 6h 50m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
