You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Dmitry Buykin (JIRA)" <ji...@apache.org> on 2018/12/03 10:10:00 UTC

[jira] [Created] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

Dmitry Buykin created KAFKA-7695:
------------------------------------

             Summary: Cannot override StreamsPartitionAssignor in configuration 
                 Key: KAFKA-7695
                 URL: https://issues.apache.org/jira/browse/KAFKA-7695
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 2.0.1, 2.0.0
            Reporter: Dmitry Buykin


Cannot override StreamsPartitionAssignor by changing property partition.assignment.strategy in KStreams 2.0.1 because the streams are crashing inside KafkaClientSupplier.getGlobalConsumer. This GlobalConsumer works only with RangeAssignor which configured by default.

Could be reproduced by setting up
`props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, StreamsPartitionAssignor.class.getName());`
For me it looks like a bug.

Opened a discussion here 

https://confluentcommunity.slack.com/archives/C48AHTCUQ/p1543395977453700

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)