[
https://issues.apache.org/jira/browse/KAFKA-5769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5769:
---
Affects Version/s: 0.11.0.0
> Transient test failure
>
[
https://issues.apache.org/jira/browse/KAFKA-5769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146297#comment-16146297
]
Matthias J. Sax commented on KAFKA-5769:
This affect 0.11.0 branch, too:
{noformat}
[
https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151848#comment-16151848
]
Matthias J. Sax commented on KAFKA-5825:
For transactions to work, you need to have at least 3
[
https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149596#comment-16149596
]
Matthias J. Sax commented on KAFKA-4366:
[~pvg] You should use the newly introduced overload for
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5818:
---
Affects Version/s: (was: 0.11.0.0)
1.0.0
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5818:
---
Summary: KafkaStreams state transitions not correct (was: Kafka Stream
state transitions not
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5818:
---
Fix Version/s: 1.0.0
0.11.0.1
> KafkaStreams state transitions not correct
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153081#comment-16153081
]
Matthias J. Sax commented on KAFKA-4327:
[~jeqo] We cannot have a dependency to core module. Thus,
[
https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146056#comment-16146056
]
Matthias J. Sax commented on KAFKA-5786:
There was a second PR for 0.11.0 branch
[
https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146087#comment-16146087
]
Matthias J. Sax commented on KAFKA-5779:
I understand your point of view (it's absolutely valid).
[
https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192070#comment-16192070
]
Matthias J. Sax commented on KAFKA-5936:
Don't think so. Will move to {{1.1.0}}.
> KafkaProducer
[
https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5936:
---
Fix Version/s: (was: 1.0.0)
1.0.1
1.1.0
>
[
https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5936:
---
Affects Version/s: 1.0.0
> KafkaProducer should not wrap InterruptedException in close() with
Matthias J. Sax created KAFKA-6048:
--
Summary: Support negative record timestamps
Key: KAFKA-6048
URL: https://issues.apache.org/jira/browse/KAFKA-6048
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200726#comment-16200726
]
Matthias J. Sax commented on KAFKA-6048:
You can always start a KIP -- but it will be a large
Matthias J. Sax created KAFKA-6058:
--
Summary: Add "describe consumer group" to KafkaAdminClient
Key: KAFKA-6058
URL: https://issues.apache.org/jira/browse/KAFKA-6058
Project: Kafka
Issue
Matthias J. Sax created KAFKA-6108:
--
Summary: Synchronizing on commits and StandbyTasks can be improved
Key: KAFKA-6108
URL: https://issues.apache.org/jira/browse/KAFKA-6108
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16215564#comment-16215564
]
Matthias J. Sax commented on KAFKA-6106:
IMHO, both scenarios (block all processing to speed up
[
https://issues.apache.org/jira/browse/KAFKA-6170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249040#comment-16249040
]
Matthias J. Sax commented on KAFKA-6170:
Does this subsume KAFKA-4857 ?
> Add the AdminClient in
[
https://issues.apache.org/jira/browse/KAFKA-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6215:
--
Assignee: Matthias J. Sax
> KafkaStreamsTest fails in trunk
>
[
https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6273:
---
Component/s: streams
> Allow names for windowing joins
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267292#comment-16267292
]
Matthias J. Sax commented on KAFKA-6273:
Thanks for the JIRA. All public API changes require a
[
https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6273:
---
Labels: needs-kip (was: )
> Allow names for windowing joins
>
[
https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6273:
---
Affects Version/s: 1.0.0
> Allow names for windowing joins
> ---
[
https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269034#comment-16269034
]
Matthias J. Sax commented on KAFKA-6048:
[~james.c] It seems you did loose interest to work on
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269010#comment-16269010
]
Matthias J. Sax commented on KAFKA-5882:
Hmmm... Can you do a
[
https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6048:
--
Assignee: Konstantin Chukhlomin (was: james chien)
> Support negative record
[
https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6249.
Resolution: Duplicate
> Interactive query downtime when node goes down even with standby
[
https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268997#comment-16268997
]
Matthias J. Sax commented on KAFKA-6249:
Thanks. I understand what you are saying. This is related
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264926#comment-16264926
]
Matthias J. Sax edited comment on KAFKA-6269 at 11/24/17 5:14 AM:
--
Had a
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264926#comment-16264926
]
Matthias J. Sax commented on KAFKA-6269:
Had a look into the code, and I think I understand the
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264921#comment-16264921
]
Matthias J. Sax commented on KAFKA-6269:
Thanks for reporting this. If you get the exception {{Log
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6269:
---
Fix Version/s: 1.0.1
1.1.0
> KTable state restore fails after rebalance
>
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6269:
---
Priority: Blocker (was: Major)
> KTable state restore fails after rebalance
>
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266321#comment-16266321
]
Matthias J. Sax commented on KAFKA-6269:
In the PR linked below, we changed the
[
https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266322#comment-16266322
]
Matthias J. Sax commented on KAFKA-5632:
No update. You are referring to KAFKA-5311 with regard to
[
https://issues.apache.org/jira/browse/KAFKA-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6259:
--
Assignee: Matthias J. Sax
> Make KafkaStreams.cleanup() clean global state directory
>
[
https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263585#comment-16263585
]
Matthias J. Sax commented on KAFKA-6260:
I did a quick test locally but could not reproduce this:
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270403#comment-16270403
]
Matthias J. Sax commented on KAFKA-5882:
Thanks for the hint with KAFKA-6260 -- we should double
[
https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16271345#comment-16271345
]
Matthias J. Sax commented on KAFKA-6150:
Is this the same as KAFKA-6038 ?
> Make Repartition
[
https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16271398#comment-16271398
]
Matthias J. Sax commented on KAFKA-6282:
Transactions by default require a replication factor of
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272013#comment-16272013
]
Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:56 AM:
--
About
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272013#comment-16272013
]
Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:55 AM:
--
About
[
https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272013#comment-16272013
]
Matthias J. Sax commented on KAFKA-6269:
About the workaround. You could mask {{null}} with a
[
https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273302#comment-16273302
]
Matthias J. Sax commented on KAFKA-6282:
Glad it's resolved. Agreed that we should update some
[
https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273546#comment-16273546
]
Matthias J. Sax commented on KAFKA-6282:
[~hachikuji] I'll take care of it.
> exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264806#comment-16264806
]
Matthias J. Sax commented on KAFKA-6248:
It is compatible:
[
https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263424#comment-16263424
]
Matthias J. Sax commented on KAFKA-6249:
Atm, it is not possible to query StandbyTasks -- for this
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16271405#comment-16271405
]
Matthias J. Sax commented on KAFKA-5882:
The JIRA is marked for {{0.11.0.0}}: there,
[
https://issues.apache.org/jira/browse/KAFKA-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277391#comment-16277391
]
Matthias J. Sax commented on KAFKA-6302:
Topic deleting is async -- thus, you will need to put a
Matthias J. Sax created KAFKA-6377:
--
Summary: Flaky test BufferPoolTest.testBlockTimeout
Key: KAFKA-6377
URL: https://issues.apache.org/jira/browse/KAFKA-6377
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274781#comment-16274781
]
Matthias J. Sax commented on KAFKA-6282:
Opened https://github.com/apache/kafka/pull/4284
>
[
https://issues.apache.org/jira/browse/KAFKA-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6297:
---
Description:
Today if the consumer is talking to an older versioned broker that does not
[
https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6265:
--
Assignee: Richard Yu
> GlobalKTable missing #queryableStoreName()
>
[
https://issues.apache.org/jira/browse/KAFKA-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4999:
--
Assignee: Richard Yu
> Add convenience overload for seek* methods
>
[
https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16293467#comment-16293467
]
Matthias J. Sax commented on KAFKA-6265:
[~Yohan123] Please assign ticket to yourself when you
[
https://issues.apache.org/jira/browse/KAFKA-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6302:
--
Assignee: Matthias J. Sax
> Topic can not be recreated after it is deleted
>
[
https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6376:
---
Labels: needs-kip (was: )
> Improve Streams metrics for skipped recrods
>
[
https://issues.apache.org/jira/browse/KAFKA-6323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16293898#comment-16293898
]
Matthias J. Sax commented on KAFKA-6323:
I like this. Having consistent behavior should improve
[
https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6376:
---
Summary: Improve Streams metrics for skipped records (was: Improve Streams
metrics for
Matthias J. Sax created KAFKA-6376:
--
Summary: Improve Streams metrics for skipped recrods
Key: KAFKA-6376
URL: https://issues.apache.org/jira/browse/KAFKA-6376
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3625:
---
Labels: needs-kip user-experience (was: user-experience)
> Move kafka-streams test fixtures
[
https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-3625:
--
Assignee: Matthias J. Sax
> Move kafka-streams test fixtures into a published package
[
https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295597#comment-16295597
]
Matthias J. Sax commented on KAFKA-6328:
You can create as many branches in your own Kafka GitHub
[
https://issues.apache.org/jira/browse/KAFKA-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6382:
---
Description:
Constructors of {{ProducerConfig}} and {{ConsumerConfig}} are not public atm.
Matthias J. Sax created KAFKA-6381:
--
Summary: Improve KafkaStreamsTest for localThreadMetadata
Key: KAFKA-6381
URL: https://issues.apache.org/jira/browse/KAFKA-6381
Project: Kafka
Issue
Matthias J. Sax created KAFKA-6382:
--
Summary: Make ProducerConfig and ConsumerConfig constructors public
Key: KAFKA-6382
URL: https://issues.apache.org/jira/browse/KAFKA-6382
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295406#comment-16295406
]
Matthias J. Sax commented on KAFKA-6323:
It's a fair question. I personally like code that is as
[
https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295412#comment-16295412
]
Matthias J. Sax commented on KAFKA-6328:
Thanks for the patch. Please assign the JIRA to yourself
[
https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16292054#comment-16292054
]
Matthias J. Sax commented on KAFKA-6367:
{quote}
We can't automatically use {{nextPosition - 1}}
[
https://issues.apache.org/jira/browse/KAFKA-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6355:
---
Component/s: unit tests
> transient failure in
>
Matthias J. Sax created KAFKA-6354:
--
Summary: Update KStream JavaDoc with regard to KIP-182
Key: KAFKA-6354
URL: https://issues.apache.org/jira/browse/KAFKA-6354
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16288462#comment-16288462
]
Matthias J. Sax commented on KAFKA-5397:
Thanks for your reply. Hope you can try out Kafka Streams
[
https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6386:
---
Summary: Deprecate KafkaStreams constructor taking StreamsConfig parameter
(was: Deprecate
Matthias J. Sax created KAFKA-6386:
--
Summary: Deprecate KafkaStreams constructor talking StreamsConfig
parameter
Key: KAFKA-6386
URL: https://issues.apache.org/jira/browse/KAFKA-6386
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6386:
---
Description:
Currently, {{KafkaStreams}} constructor has overloads that take either
[
https://issues.apache.org/jira/browse/KAFKA-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6382:
---
Labels: kip (was: )
> Make ProducerConfig and ConsumerConfig constructors public
>
[
https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4263:
Assignee: Matthias J. Sax (was: Damian Guy)
Reopening this. Happened again:
[
https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6383:
---
Affects Version/s: 1.0.0
> StreamThread.shutdown doesn't clean up completely when called
[
https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6383:
---
Component/s: streams
> StreamThread.shutdown doesn't clean up completely when called before
[
https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16257307#comment-16257307
]
Matthias J. Sax commented on KAFKA-6048:
Thanks for the input. Doing the less intrusive might be a
[
https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6167:
---
Fix Version/s: 1.0.1
> Timestamp on streams directory contains a colon, which is an illegal
[
https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6167:
---
Priority: Blocker (was: Major)
> Timestamp on streams directory contains a colon, which is
[
https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250711#comment-16250711
]
Matthias J. Sax commented on KAFKA-5254:
This seems to be resolve by KAFKA-5651 \cc [~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250727#comment-16250727
]
Matthias J. Sax commented on KAFKA-4696:
[~damianguy] Is this resolved already? IIRC, we don't
[
https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250720#comment-16250720
]
Matthias J. Sax commented on KAFKA-4730:
Is this covered by KAFKA-5651 ? \cc [~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250719#comment-16250719
]
Matthias J. Sax commented on KAFKA-4729:
Is this resolved via KAFKA-5651 \cc [~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6162.
Resolution: Duplicate
> Stream Store tries to create directory with invalid name on Windows
[
https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250869#comment-16250869
]
Matthias J. Sax commented on KAFKA-4281:
This seems to be covered via KAFKA-5651. \cc [~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6237:
---
Component/s: streams
> stream stopped working after exception: Cannot execute transactional
[
https://issues.apache.org/jira/browse/KAFKA-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259631#comment-16259631
]
Matthias J. Sax commented on KAFKA-6239:
How is this different to KAFKA-6236 ?
> Consume group
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-6237:
> stream stopped working after exception: Cannot execute transactional method
> because we are
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259618#comment-16259618
]
Matthias J. Sax edited comment on KAFKA-6237 at 11/20/17 6:38 PM:
--
Thanks
[
https://issues.apache.org/jira/browse/KAFKA-6236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6236:
---
Component/s: streams
> stream not picking data from topic - after rebalancing
>
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6237.
Resolution: Duplicate
Thanks for reporting this. It is a duplicate and the issue is fixed
[
https://issues.apache.org/jira/browse/KAFKA-6236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259612#comment-16259612
]
Matthias J. Sax commented on KAFKA-6236:
Thanks for reporting this. What is the reason for your
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6237:
---
Component/s: core
> stream stopped working after exception: Cannot execute transactional
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6237:
---
Labels: exactly-once (was: )
> stream stopped working after exception: Cannot execute
[
https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261390#comment-16261390
]
Matthias J. Sax commented on KAFKA-6205:
In {{1.0}} you can register a {{StateRestoreListener}}:
[
https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261575#comment-16261575
]
Matthias J. Sax commented on KAFKA-6249:
Thanks for giving feedback :) It seems that this is a
201 - 300 of 5690 matches
Mail list logo
