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)
