clear query| facets| time Search criteria: .   Results from 1 to 10 from 429 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9173] StreamsPartitionAssignor assigns partitions to only one worker - Kafka - [issue]
...I'm running a distributed KafkaStreams application on 10 worker nodes, subscribed to 21 topics with 10 partitions in each. I'm only using a Processor interface, and a persistent state store....
http://issues.apache.org/jira/browse/KAFKA-9173    Author: Oleg Muravskiy , 2019-12-06, 20:03
[KAFKA-7588] Rationalize configurations passed to pluggable APIs - Kafka - [issue]
...There are a lot of extensions points both on the client and server sides. Most of these pluggable APIs are configurable but the configurations they receive are not the same.For example, Seri...
http://issues.apache.org/jira/browse/KAFKA-7588    Author: Mickael Maison , 2019-12-06, 19:58
[KAFKA-7489] ConnectDistributedTest is always running broker with dev version - Kafka - [issue]
...Test classkafkatest.tests.connect.connect_distributed_test.ConnectDistributedTestDetailstest_broker_compatibility is parametrized with different types of brokers, yet it is passed as string ...
http://issues.apache.org/jira/browse/KAFKA-7489    Author: Andras Katona , 2019-12-06, 19:48
[expand - 2 more] - How to set concrete names for state stores and internal topics backed by these - Kafka - [mail # user]
...Hi SachinWe are using a small helper method to keep this readable:private  MaterializedmaterializedWith(String name, Serde keySerde, Serde valueSerde){    Materialized materia...
   Author: Patrik Kleindl , John Roesler , ... , 2019-12-06, 19:24
[KAFKA-9091] KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type - Kafka - [issue]
...KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type...
http://issues.apache.org/jira/browse/KAFKA-9091    Author: Colin McCabe , 2019-12-06, 19:20
Static Membership AND Invalid IP addresses forConsumers - Kafka - [mail # user]
...I forgot to note that we are using spot instances AND static membership.  I was able to confirm that setting application.server with the correct ip-address seems to result in the correc...
   Author: David Garcia , 2019-12-06, 19:09
[expand - 14 more] - Broker Interceptors - Kafka - [mail # user]
...to me this is an "API vs SPI" discussion.pluggable broker bits should fall on the "SPI" side, where tightercoupling is the price you pay for power and performance, the targetaudience is smal...
   Author: radai , Ismael Juma , ... , 2019-12-06, 19:01
[expand - 3 more] - Proposal for EmbeddedKafkaCluster: Support JUnit 5 Extension in addition to JUnit 4 Rule - Kafka - [mail # dev]
...Hi Tommy,There are some practically ancient discussions around doing this exact thing, but they haven't generally come to fruition because EmbeddedKafkaCluster itself isn't really a slam dun...
   Author: John Roesler , Thomas Becker , ... , 2019-12-06, 18:59
[KAFKA-9282] Consider more flexible node grouping for Pattern subscription - Kafka - [issue]
...The current grouping for input topics using pattern subscription creates a single node group for all matching topics, meaning the number of tasks scales with the maximum partition count acro...
http://issues.apache.org/jira/browse/KAFKA-9282    Author: Sophie Blee-Goldman , 2019-12-06, 18:59
[KAFKA-9281] Consider more flexible node grouping for Pattern subscription - Kafka - [issue]
...Input topics subscribed to using pattern subscription will currently all be grouped into the same node group, meaning the number of tasks is determined by the maximum partition count of any ...
http://issues.apache.org/jira/browse/KAFKA-9281    Author: Sophie Blee-Goldman , 2019-12-06, 18:47