You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Akihito Nakano (JIRA)" <ji...@apache.org> on 2017/10/15 08:53:02 UTC
[jira] [Created] (KAFKA-6063) StreamsException is thrown after the
changing `partitions`
Akihito Nakano created KAFKA-6063:
-------------------------------------
Summary: StreamsException is thrown after the changing `partitions`
Key: KAFKA-6063
URL: https://issues.apache.org/jira/browse/KAFKA-6063
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 0.11.0.0
Environment: macOS 10.12
kafka 0.11.0.1
Reporter: Akihito Nakano
"org.apache.kafka.streams.errors.StreamsException" is thrown in following case.
h3. Create topic
```
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 6 --topic word-count-input
```
h3. Create Kafka Streams Application
```
public class WordCountApp {
public static void main(String[] args) {
Properties config = new Properties();
config.put(StreamsConfig.APPLICATION_ID_CONFIG, "wordcount-application");
...
...
```
h3. Ensure that it works fine
```
$ java -jar wordcount.jar
KafkaStreams processID: b4a559cb-7075-4ece-a718-5043a432900b
StreamsThread appId: wordcount-application
...
...
```
h3. Change "partitions"
```
$ bin/kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 8 --topic word-count-input
Adding partitions succeeded!
```
h3. When I start Application, StreamsException is thrown
```
$ java -jar wordcount.jar
KafkaStreams processID: 8a9cbf03-b841-4cb2-9d44-6456b4520522
StreamsThread appId: wordcount-applicationn
...
...
Exception in thread "wordcount-application-8a9cbf03-b841-4cb2-9d44-6456b4520522-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Could not create internal topics.
```
If I change the application id, Application works again.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)