Skip to content

Commit

Permalink
Merge pull request #8 from soundvibe/2.6.1
Browse files Browse the repository at this point in the history
2.6.1
  • Loading branch information
soundvibe committed Feb 4, 2021
2 parents 13dea01 + 481f3c0 commit 416042f
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 6 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@

# kafka-config

Easy to use type-safe builders for kafka clients.
Easy to use type-safe builders for kafka clients.
Supports Java >= 8.
kafka-config version aligns with kafka-client version.

Expand All @@ -19,7 +19,7 @@ Supported clients:
* KafkaConsumer
* KafkaProducer
* KafkaStreams
* AdminClient
* AdminClient

## Examples
```java
Expand Down Expand Up @@ -105,7 +105,7 @@ Binaries and dependency information for Maven, Ivy, Gradle and others can be fou
Example for Gradle:

```groovy
compile 'net.soundvibe:kafka-config:2.6.0'
compile 'net.soundvibe:kafka-config:2.6.1'
```

and for Maven:
Expand All @@ -114,7 +114,7 @@ and for Maven:
<dependency>
<groupId>net.soundvibe</groupId>
<artifactId>kafka-config</artifactId>
<version>2.6.0</version>
<version>2.6.1</version>
</dependency>
```

Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>net.soundvibe</groupId>
<artifactId>kafka-config</artifactId>
<version>2.6.0</version>
<version>2.6.1</version>
<packaging>jar</packaging>
<name>kafka-config</name>
<description>Typesafe configuration for Kafka clients</description>
Expand Down Expand Up @@ -36,7 +36,7 @@
<properties>
<java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<kafka.version>2.6.0</kafka.version>
<kafka.version>2.6.1</kafka.version>
</properties>

<distributionManagement>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,19 +6,23 @@
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.*;
import org.junit.jupiter.api.*;
import org.junit.jupiter.api.condition.DisabledOnOs;

import java.io.IOException;
import java.nio.file.Files;
import java.time.Duration;
import java.util.Properties;

import static org.junit.jupiter.api.Assertions.*;
import static org.junit.jupiter.api.condition.OS.WINDOWS;

@DisplayNameGeneration(DisplayNameGenerator.ReplaceUnderscores.class)
class StreamsConfigBuilderTest {

private static final String BOOTSTRAP_SERVERS = "http://localhost:9876";

@Test
@DisabledOnOs(WINDOWS)
void should_build_all_properties() throws IOException {
Properties streamProps = StreamsConfigBuilder.create()
.withBootstrapServers(BOOTSTRAP_SERVERS)
Expand Down Expand Up @@ -69,6 +73,7 @@ void should_build_all_properties() throws IOException {
}

@Test
@DisabledOnOs(WINDOWS)
void should_set_upgrade_from_to_null() {
Properties streamProps = StreamsConfigBuilder.create()
.withBootstrapServers(BOOTSTRAP_SERVERS)
Expand Down

0 comments on commit 416042f

Please sign in to comment.