So effectively Kafka supports exactly-once delivery in Kafka Streams, and the transactional producer/consumer can be used generally to provide - exactly-once delivery when transfering and processing data between Kafka topics. Exactly-once delivery for other destination systems generally requires cooperation with such systems, but Kafka provides the + exactly-once delivery when transferring and processing data between Kafka topics. Exactly-once delivery for other destination systems generally requires cooperation with such systems, but Kafka provides the offset which makes implementing this feasible (see also Kafka Connect). Otherwise, Kafka guarantees at-least-once delivery by default, and allows the user to implement at-most-once delivery by disabling retries on the producer and committing offsets in the consumer prior to processing a batch of messages. diff --git a/docs/security.html b/docs/security.html index b0183343a4b61..6ff9eba2cbfb6 100644 --- a/docs/security.html +++ b/docs/security.html @@ -220,7 +220,7 @@
-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \
username="alice" \
@@ -973,7 +973,7 @@ 7.3 Authentication using SASL
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \
username="tokenID123" \
diff --git a/release.py b/release.py
index 3573a7f843331..1cf54c4598efc 100755
--- a/release.py
+++ b/release.py
@@ -285,13 +285,13 @@ def command_stage_docs():
signing.keyId=your-gpgkeyId
signing.password=your-gpg-passphrase
signing.secretKeyRingFile=/Users/your-id/.gnupg/secring.gpg (if you are using GPG 2.1 and beyond, then this file will no longer exist anymore, and you have to manually create it from the new private key directory with "gpg --export-secret-keys -o ~/.gnupg/secring.gpg")
-8. ~/.m2/settings.xml configured for pgp signing and uploading to apache release maven, i.e.,
+8. ~/.m2/settings.xml configured for pgp signing and uploading to apache release maven, i.e.,
apache.releases.https
your-apache-id
your-apache-passwd
-
+
your-gpgkeyId
your-gpg-passphase
@@ -299,18 +299,18 @@ def command_stage_docs():
gpg-signing
your-gpgkeyId
- your-gpgkeyId
+ your-gpgkeyId
9. You may also need to update some gnupgp configs:
- ~/.gnupg/gpg-agent.conf
- allow-loopback-pinentry
+ ~/.gnupg/gpg-agent.conf
+ allow-loopback-pinentry
- ~/.gnupg/gpg.conf
- use-agent
- pinentry-mode loopback
+ ~/.gnupg/gpg.conf
+ use-agent
+ pinentry-mode loopback
- echo RELOADAGENT | gpg-connect-agent
+ echo RELOADAGENT | gpg-connect-agent
If any of these are missing, see https://cwiki.apache.org/confluence/display/KAFKA/Release+Process for instructions on setting them up.
@@ -404,7 +404,7 @@ def select_gpg_key():
cmd("remove backup java pom.xml", "rm streams/quickstart/java/pom.xml.orig")
cmd("remove backup java pom.xml", "rm streams/quickstart/java/src/main/resources/archetype-resources/pom.xml.orig")
# Command in explicit list due to messages with spaces
-cmd("Commiting version number updates", ["git", "commit", "-a", "-m", "Bump version to %s" % release_version])
+cmd("Committing version number updates", ["git", "commit", "-a", "-m", "Bump version to %s" % release_version])
# Command in explicit list due to messages with spaces
cmd("Tagging release candidate %s" % rc_tag, ["git", "tag", "-a", rc_tag, "-m", rc_tag])
rc_githash = cmd_output("git show-ref --hash " + rc_tag)
diff --git a/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java b/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java
index 289cdf0d6dc6c..de856bba2363a 100644
--- a/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java
@@ -258,7 +258,7 @@ public void shouldFailIfSinkIsParent() {
public void shouldNotAllowToAddStateStoreToNonExistingProcessor() {
mockStoreBuilder();
EasyMock.replay(storeBuilder);
- topology.addStateStore(storeBuilder, "no-such-processsor");
+ topology.addStateStore(storeBuilder, "no-such-processor");
}
@Test
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java
index 8ddb0b5004076..d49dd9d087803 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java
@@ -103,7 +103,7 @@ public void shouldAddSourceWithoutOffsetReset() {
@Test
public void shouldAddPatternSourceWithoutOffsetReset() {
final Pattern expectedPattern = Pattern.compile("test-.*");
-
+
builder.addSource(null, "source", null, stringSerde.deserializer(), stringSerde.deserializer(), Pattern.compile("test-.*"));
assertEquals(expectedPattern.pattern(), builder.sourceTopicPattern().pattern());
@@ -286,7 +286,7 @@ public void testNamedTopicMatchesAlreadyProvidedPattern() {
@Test(expected = TopologyException.class)
public void testAddStateStoreWithNonExistingProcessor() {
- builder.addStateStore(storeBuilder, "no-such-processsor");
+ builder.addStateStore(storeBuilder, "no-such-processor");
}
@Test