[
https://issues.apache.org/jira/browse/KAFKA-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-659.
Resolution: Fixed
I'll close this for now since no-one objected here or on the mailing list, so
[
https://issues.apache.org/jira/browse/KAFKA-817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-817.
Resolution: Won't Fix
I'll close this for now as I've received no feedback to the contrary
[
https://issues.apache.org/jira/browse/KAFKA-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16811841#comment-16811841
]
Loïc Monney commented on KAFKA-7755:
@Tim: This is not only specific to Kubernetes, but, as you
Bartłomiej Kępa created KAFKA-8218:
--
Summary: IllegalStateException while accessing context in
Transformer
Key: KAFKA-8218
URL: https://issues.apache.org/jira/browse/KAFKA-8218
Project: Kafka
Ernestas Vaiciukevičius created KAFKA-8226:
--
Summary: New MirrorMaker option partition.to.partition
Key: KAFKA-8226
URL: https://issues.apache.org/jira/browse/KAFKA-8226
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ernestas Vaiciukevičius updated KAFKA-8226:
---
Description:
Currently when MirrorMaker moves data between topics
[
https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16817610#comment-16817610
]
Sönke Liebau edited comment on KAFKA-8226 at 4/15/19 7:14 AM:
--
Hi [~ernisv
[
https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16817610#comment-16817610
]
Sönke Liebau edited comment on KAFKA-8226 at 4/15/19 7:14 AM:
--
Hi [~ernisv
[
https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16817610#comment-16817610
]
Sönke Liebau commented on KAFKA-8226:
-
Hi [~ernisv],
the functionality that you are implementing
[
https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819899#comment-16819899
]
Sönke Liebau commented on KAFKA-8246:
-
I believe that used to be a regular expression but was changed
[
https://issues.apache.org/jira/browse/KAFKA-6983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849545#comment-16849545
]
Gérald Quintana commented on KAFKA-6983:
Still occurs on Kafka 2.2.0.
It makes developping Kafka
Dejan Stojadinović created KAFKA-8466:
-
Summary: Remove 'jackson-module-scala' dependency (and replace it
with some code)
Key: KAFKA-8466
URL: https://issues.apache.org/jira/browse/KAFKA-8466
[
https://issues.apache.org/jira/browse/KAFKA-3288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866761#comment-16866761
]
Gérald Quintana commented on KAFKA-3288:
Zookeeper 3.5.5 is marked as stable
> Update
[
https://issues.apache.org/jira/browse/KAFKA-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866772#comment-16866772
]
Gérald Quintana commented on KAFKA-3287:
This means adding Zookeeper client SSL support in Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16872476#comment-16872476
]
Sönke Liebau commented on KAFKA-5115:
-
Hi [~MiniMizer],
we've just discussed this today and while
[
https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Gergő Barna updated KAFKA-8568:
-
Description:
This issue produced by the branch KIP-382 (I am not sure which version
Péter Gergő Barna created KAFKA-8568:
Summary: MirrorMaker 2.0 resource leak
Key: KAFKA-8568
URL: https://issues.apache.org/jira/browse/KAFKA-8568
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867719#comment-16867719
]
Péter Gergő Barna commented on KAFKA-8568:
--
tried to add null checks, it made
Jacek Żoch created KAFKA-8517:
-
Summary: A lot of WARN messages in kafka log "Received a
PartitionLeaderEpoch assignment for an epoch < latestEpoch:
Key: KAFKA-8517
URL: https://issues.apache.org/jira/brow
[
https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837510#comment-16837510
]
Sönke Liebau commented on KAFKA-8247:
-
I've experimented a bit with this, I removed all those checks
[
https://issues.apache.org/jira/browse/KAFKA-7362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836320#comment-16836320
]
Ferlin-Sutton Léo commented on KAFKA-7362:
--
I can see the implementation is being worked
[
https://issues.apache.org/jira/browse/KAFKA-8359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840262#comment-16840262
]
Sönke Liebau commented on KAFKA-8359:
-
I dug around a little as to where this default comes from
[
https://issues.apache.org/jira/browse/KAFKA-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841564#comment-16841564
]
Marc Löhe commented on KAFKA-8163:
--
I experience the same problem with Connect 2.2 and Debezium 0.9.5
[
https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau reassigned KAFKA-8247:
---
Assignee: Sönke Liebau
> Duplicate error handling in kafka-server-start.sh and actual Ka
[
https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835344#comment-16835344
]
Sönke Liebau commented on KAFKA-8247:
-
So..these checks actually have a little bit of sense, because
[
https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877560#comment-16877560
]
许晋瑞 commented on KAFKA-8624:
Could you provide the versions of client and server that you use? Maybe I can
[
https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873440#comment-16873440
]
Jose A. Iñigo commented on KAFKA-7077:
--
Hi [~stephane.maa...@gmail.com], are there any plans
Marc Löhe created KAFKA-8659:
Summary: SetSchemaMetadata SMT fails on records with null value
and schema
Key: KAFKA-8659
URL: https://issues.apache.org/jira/browse/KAFKA-8659
Project: Kafka
Marc Löhe created KAFKA-8660:
Summary: Make ValueToKey SMT work only on a whitelist of topics
Key: KAFKA-8660
URL: https://issues.apache.org/jira/browse/KAFKA-8660
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marc Löhe updated KAFKA-8660:
-
Description:
For source connectors that publish on multiple topics it is essential to be
able
[
https://issues.apache.org/jira/browse/KAFKA-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824252#comment-16824252
]
Sönke Liebau commented on KAFKA-8274:
-
hi [~hrishi_dypim], can you add some more detail around
[
https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825442#comment-16825442
]
Sönke Liebau commented on KAFKA-8247:
-
Actually, upon further digging, the same check can also
Sönke Liebau created KAFKA-8292:
---
Summary: Add support for --version parameter to command line tools
Key: KAFKA-8292
URL: https://issues.apache.org/jira/browse/KAFKA-8292
Project: Kafka
Issue
Sönke Liebau created KAFKA-8247:
---
Summary: Duplicate error handling in kafka-server-start.sh and
actual Kafka class
Key: KAFKA-8247
URL: https://issues.apache.org/jira/browse/KAFKA-8247
Project: Kafka
Xavier Léauté created KAFKA-8806:
Summary: Kafka.poll spends significant amount of time in
KafkaConsumer.updateAssignmentMetadataIfNeeded
Key: KAFKA-8806
URL: https://issues.apache.org/jira/browse/KAFKA-8806
Aljoscha Pörtner created KAFKA-8786:
---
Summary: Deprecated Gradle features making it incompatible with
Gradle 6.0.
Key: KAFKA-8786
URL: https://issues.apache.org/jira/browse/KAFKA-8786
Project
[
https://issues.apache.org/jira/browse/KAFKA-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905827#comment-16905827
]
Sönke Liebau commented on KAFKA-8792:
-
I agree, port 8080 tends to be one of the first ports software
[
https://issues.apache.org/jira/browse/KAFKA-8758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stéphane Derosiaux updated KAFKA-8758:
--
Summary: Discover your KafkaPrincipal (was: Know your KafkaPrincipal)
> Discover y
Fábio Silva created KAFKA-8818:
--
Summary: CreatePartitions Request protocol documentation
Key: KAFKA-8818
URL: https://issues.apache.org/jira/browse/KAFKA-8818
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Description:
CreatePartitions Request protocol documentation contains a invalid type
ARRAY(INT32
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Priority: Minor (was: Major)
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Description:
CreatePartitions Request protocol documentation contains a invalid type
ARRAY(INT32
[
https://issues.apache.org/jira/browse/KAFKA-8698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8698:
---
Labels: documentation protocol-documentation (was: documentation)
> ListOffsets Response proto
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Labels: documentation protocol-documentation (was: d)
> CreatePartitions Request proto
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Description: CreatePartitions Request protocol documentation contains a
invalid type ARRAY(INT32
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Description: CreatePartitions Request protocol documentation contains a
invalid type ARRAY(INT32
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Labels: d (was: )
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Component/s: documentation
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Description: CreatePartitions Request protocol documentation contains a
invalid type ARRAY(INT32
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Priority: Major (was: Minor)
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-8806:
-
Description:
Comparing the performance profile of 2.2.0 and 2.3.0, we are seeing significant
[
https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-8806:
-
Description:
Comparing the performance profile of 2.2.0 and 2.3.0, we are seeing significant
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Reviewer: (was: Asutosh Pandya)
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8818:
---
Reviewer: Asutosh Pandya
> CreatePartitions Request protocol documentat
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914260#comment-16914260
]
Fábio Silva commented on KAFKA-8818:
[~asutosh_pandya] may you take a look
[
https://issues.apache.org/jira/browse/KAFKA-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914334#comment-16914334
]
Sönke Liebau commented on KAFKA-8825:
-
I think that might also help in DR / failover scenarios where
[
https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920779#comment-16920779
]
Reynir Hübner commented on KAFKA-8705:
--
I get the same exception on version *2.2.1* when
[
https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924019#comment-16924019
]
Fábio Silva commented on KAFKA-8818:
The syntax on documentation is wrong. To represent an array
[
https://issues.apache.org/jira/browse/KAFKA-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marc Löhe updated KAFKA-8660:
-
Description:
For source connectors that publish on multiple topics (e.g.
[Debezium|[https://debezium.io
[
https://issues.apache.org/jira/browse/KAFKA-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924269#comment-16924269
]
Marc Löhe commented on KAFKA-8660:
--
I added a proof of concept implementation of a topic whitelist
[
https://issues.apache.org/jira/browse/KAFKA-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924150#comment-16924150
]
Marc Löhe commented on KAFKA-8660:
--
There hasn't been any progress on this one lately. What can I do
[
https://issues.apache.org/jira/browse/KAFKA-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pascal Büttiker updated KAFKA-8917:
---
Description:
As described in KAFKA-7718, headers are promoted by the "triggering&qu
Pascal Büttiker created KAFKA-8917:
--
Summary: When performing a Left/Right-Join, pick the headers of
the same side
Key: KAFKA-8917
URL: https://issues.apache.org/jira/browse/KAFKA-8917
Project
[
https://issues.apache.org/jira/browse/KAFKA-8911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931614#comment-16931614
]
Michał commented on KAFKA-8911:
---
The test failure seems a bit random to me but I can not restart
[
https://issues.apache.org/jira/browse/KAFKA-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pascal Büttiker updated KAFKA-8917:
---
Description:
As described in KAFKA-7718, headers are promoted by the "triggering&qu
Michał created KAFKA-8911:
-
Summary: Implicit TimeWindowedSerde creates Serde with null inner
serializer
Key: KAFKA-8911
URL: https://issues.apache.org/jira/browse/KAFKA-8911
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930508#comment-16930508
]
Michał commented on KAFKA-8911:
---
PS I can make a fix MR on Github, but I dont know the procedure here
[
https://issues.apache.org/jira/browse/KAFKA-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bartłomiej Kępa closed KAFKA-8218.
--
> IllegalStateException while accessing context in Transfor
[
https://issues.apache.org/jira/browse/KAFKA-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-1099.
-
Resolution: Abandoned
Closing this as abandoned after asking for feedback on the dev list
[
https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895901#comment-16895901
]
Sönke Liebau commented on KAFKA-1566:
-
Is this still something we are interested in doing? I just
[
https://issues.apache.org/jira/browse/KAFKA-822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-822.
Resolution: Abandoned
Closing this as abandoned after asking for feedback on the dev list. Its
[
https://issues.apache.org/jira/browse/KAFKA-1016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-1016.
-
Resolution: Not A Problem
Closing this as "not a problem", I believe the Purgator
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sönke Liebau resolved KAFKA-.
-
Resolution: Abandoned
Closing as abandoned after no objections on dev list. If this is indeed
[
https://issues.apache.org/jira/browse/KAFKA-8698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fábio Silva updated KAFKA-8698:
---
Description:
The documentation of ListOffsets Response (Version: 0) appears to have an typo
[
https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900305#comment-16900305
]
Stéphane Derosiaux commented on KAFKA-6598:
---
The KIP is up:
[https://cwiki.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-8754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stéphane Derosiaux updated KAFKA-8754:
--
Attachment: image-2019-08-05-22-45-01-527.png
> Connect API: Expose the l
[
https://issues.apache.org/jira/browse/KAFKA-8754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900400#comment-16900400
]
Stéphane Derosiaux commented on KAFKA-8754:
---
I did a tiny work from connector-plugins
Stéphane Derosiaux created KAFKA-8754:
-
Summary: Connect API: Expose the list of available transformations
Key: KAFKA-8754
URL: https://issues.apache.org/jira/browse/KAFKA-8754
Project: Kafka
Stéphane Derosiaux created KAFKA-8758:
-
Summary: Know your KafkaPrincipal
Key: KAFKA-8758
URL: https://issues.apache.org/jira/browse/KAFKA-8758
Project: Kafka
Issue Type: Wish
[
https://issues.apache.org/jira/browse/KAFKA-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887719#comment-16887719
]
Sönke Liebau commented on KAFKA-8679:
-
Hi [~weichu], this looks to me to be a duplicate of KAFKA-8670
[
https://issues.apache.org/jira/browse/KAFKA-1016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888768#comment-16888768
]
Sönke Liebau commented on KAFKA-1016:
-
Is this still relevant after the Purgatory redesign in KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888771#comment-16888771
]
Sönke Liebau commented on KAFKA-822:
While not 100% sure how this looks in today's code, but I do
[
https://issues.apache.org/jira/browse/KAFKA-1234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888782#comment-16888782
]
Sönke Liebau commented on KAFKA-1234:
-
I'm unsure what the "gospel" way of doing this
[
https://issues.apache.org/jira/browse/KAFKA-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888786#comment-16888786
]
Sönke Liebau commented on KAFKA-1099:
-
Pretty sure this information has not been included
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888789#comment-16888789
]
Sönke Liebau commented on KAFKA-:
-
I've not tested this, but there has been some work around
Fábio Silva created KAFKA-8698:
--
Summary: ListOffsets Response protocol documentation
Key: KAFKA-8698
URL: https://issues.apache.org/jira/browse/KAFKA-8698
Project: Kafka
Issue Type: Bug
Michał created KAFKA-8924:
-
Summary: Default grace period (-1) of TimeWindows causes suppress
to never emit events
Key: KAFKA-8924
URL: https://issues.apache.org/jira/browse/KAFKA-8924
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał updated KAFKA-8924:
--
Description:
#Problem
The default creation of TimeWindows, like
{code}
TimeWindows.of(ofMillis(xxx))
{code
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał updated KAFKA-8924:
--
Description:
#Problem
The default creation of TimeWindows, like
{code}
TimeWindows.of(ofMillis(xxx))
{code
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał updated KAFKA-8924:
--
Description:
h2. Problem
The default creation of TimeWindows, like
{code}
TimeWindows.of(ofMillis(xxx
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934644#comment-16934644
]
Michał commented on KAFKA-8924:
---
[~cadonna] as we discussed here I will adjust the TimeWindows creation
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934644#comment-16934644
]
Michał edited comment on KAFKA-8924 at 9/20/19 6:18 PM:
[~cadonna] as we
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał updated KAFKA-8924:
--
Issue Type: Improvement (was: Bug)
Summary: Default grace period (-1) of TimeWindows causes suppress
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933762#comment-16933762
]
Michał commented on KAFKA-8924:
---
To be honest my first thought was that if I do not specify the grace
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał updated KAFKA-8924:
--
Description:
h2. Problem
The default creation of TimeWindows, like
{code}
TimeWindows.of(ofMillis(xxx
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał reassigned KAFKA-8924:
-
Assignee: Michał
> Default grace period (-1) of TimeWindows causes suppress to emit events after
&g
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934171#comment-16934171
]
Michał commented on KAFKA-8924:
---
Hi.
Thanks a lot for such a detailed explanation. I think I understand
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934171#comment-16934171
]
Michał edited comment on KAFKA-8924 at 9/20/19 7:42 AM:
Hi.
Thanks a lot
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934171#comment-16934171
]
Michał edited comment on KAFKA-8924 at 9/20/19 7:46 AM:
Hi.
Thanks a lot
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934187#comment-16934187
]
Michał commented on KAFKA-8924:
---
{quote}
Regarding the log message, that wasn't it, although that message
301 - 400 of 74676 matches
Mail list logo
