[
https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4517:
-
Priority: Blocker (was: Minor)
> Remove kafka-consumer-offset-checker.sh scr
[
https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788842#comment-15788842
]
Ewen Cheslack-Postava commented on KAFKA-4517:
--
Upgraded to blocker
[
https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4517:
-
Fix Version/s: 0.11.0.0
> Remove kafka-consumer-offset-checker.sh script si
[
https://issues.apache.org/jira/browse/KAFKA-4530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4530.
--
Resolution: Duplicate
Assignee: Ewen Cheslack-Postava
> cant stop ka
[
https://issues.apache.org/jira/browse/KAFKA-4531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788707#comment-15788707
]
Ewen Cheslack-Postava commented on KAFKA-4531:
--
Could we bake this
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3856:
-
Assignee: Matthias J. Sax (was: Jeyhun Karimov)
> Move inner classes accessi
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788683#comment-15788683
]
Ewen Cheslack-Postava commented on KAFKA-3856:
--
[~mjsax] 6mo seems
[
https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788679#comment-15788679
]
Ewen Cheslack-Postava commented on KAFKA-3135:
--
Also, /cc [~hachikuji] s
[
https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788677#comment-15788677
]
Ewen Cheslack-Postava commented on KAFKA-3135:
--
[~jeffwidman] I'v
[
https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3135:
-
Affects Version/s: 0.10.1.0
0.9.0.1
[
https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788664#comment-15788664
]
Ewen Cheslack-Postava commented on KAFKA-3539:
--
http://
[
https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788627#comment-15788627
]
Ewen Cheslack-Postava commented on KAFKA-4550:
--
One of the failures repo
[
https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788626#comment-15788626
]
Ewen Cheslack-Postava commented on KAFKA-4550:
--
Seems like the second i
[
https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788615#comment-15788615
]
Ewen Cheslack-Postava commented on KAFKA-4514:
--
How broadly is zstd b
[
https://issues.apache.org/jira/browse/KAFKA-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788347#comment-15788347
]
Ewen Cheslack-Postava commented on KAFKA-4556:
--
Can you be more spec
I've granted you permissions, you should now be able to edit the main KIP
page and add a new KIP.
-Ewen
On Fri, Dec 30, 2016 at 2:58 PM, Aarti Gupta wrote:
> Hey devs,
>
> My jira username is aartigupta
> and my wiki username happens to be aartiguptaa
> (not sure how that happened)
>
> I alrea
g implemented by
> > > > connectors in divergent ways: RegexRouter, Insert, Replace,
> > > HoistToStruct,
> > > > ExtractFromStruct
> > > >
> > > > On Wed, Dec 14, 2016 at 6:00 PM Gwen Shapira
> > wrote:
> > > >
>
[
https://issues.apache.org/jira/browse/KAFKA-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788234#comment-15788234
]
Ewen Cheslack-Postava commented on KAFKA-4572:
--
[~vahid] The versio
[
https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788229#comment-15788229
]
Ewen Cheslack-Postava commented on KAFKA-3297:
--
Yeah, part of
[
https://issues.apache.org/jira/browse/KAFKA-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2196:
-
Fix Version/s: 0.9.0.0
> remove roundrobin identical topic constraint in consu
[
https://issues.apache.org/jira/browse/KAFKA-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786960#comment-15786960
]
Ewen Cheslack-Postava commented on KAFKA-2196:
--
Based on git history, l
[
https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786948#comment-15786948
]
Ewen Cheslack-Postava commented on KAFKA-3297:
--
[~jeffwidman] I don
[
https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3297:
-
Component/s: consumer
> More optimally balanced partition assignment strat
[
https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786941#comment-15786941
]
Ewen Cheslack-Postava commented on KAFKA-3502:
--
I've seen this in
[
https://issues.apache.org/jira/browse/KAFKA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786931#comment-15786931
]
Ewen Cheslack-Postava commented on KAFKA-2019:
--
[~jeffwidman] I updated
[
https://issues.apache.org/jira/browse/KAFKA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2019:
-
Summary: Old consumer RoundRobinAssignor clusters by consumer (was
[
https://issues.apache.org/jira/browse/KAFKA-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786920#comment-15786920
]
Ewen Cheslack-Postava commented on KAFKA-2331:
--
This seems like a sepa
[
https://issues.apache.org/jira/browse/KAFKA-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2331:
-
Component/s: (was: core)
consumer
clients
[
https://issues.apache.org/jira/browse/KAFKA-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786745#comment-15786745
]
Ewen Cheslack-Postava edited comment on KAFKA-4567 at 12/30/16 3:1
[
https://issues.apache.org/jira/browse/KAFKA-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786745#comment-15786745
]
Ewen Cheslack-Postava commented on KAFKA-4567:
--
Given some future secu
[
https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786719#comment-15786719
]
Ewen Cheslack-Postava commented on KAFKA-2260:
--
[~wwarshaw] That so
[
https://issues.apache.org/jira/browse/KAFKA-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786713#comment-15786713
]
Ewen Cheslack-Postava commented on KAFKA-4570:
--
[~zander] You'r
[
https://issues.apache.org/jira/browse/KAFKA-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786707#comment-15786707
]
Ewen Cheslack-Postava commented on KAFKA-4571:
--
Since another consumer g
[
https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4115:
-
Fix Version/s: 0.10.2.0
> Grow default heap settings for distributed Connect f
[
https://issues.apache.org/jira/browse/KAFKA-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786244#comment-15786244
]
Ewen Cheslack-Postava commented on KAFKA-3947:
--
[~kawamuray] Any progres
[
https://issues.apache.org/jira/browse/KAFKA-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4404:
-
Fix Version/s: 0.10.2.0
Status: Patch Available (was: Open)
>
[
https://issues.apache.org/jira/browse/KAFKA-4092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4092.
--
Resolution: Fixed
Reviewer: Ewen Cheslack-Postava
Fix Version/s
[
https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4551:
-
Labels: system-test-failure (was: )
> StreamsSmokeTest.test_streams intermitt
[
https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4551:
-
Assignee: Damian Guy
> StreamsSmokeTest.test_streams intermittent fail
[
https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779574#comment-15779574
]
Ewen Cheslack-Postava commented on KAFKA-4551:
--
Another case of this t
[
https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4551:
-
Fix Version/s: 0.10.1.2
> StreamsSmokeTest.test_streams intermittent fail
[
https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15776893#comment-15776893
]
Ewen Cheslack-Postava commented on KAFKA-4558:
--
And this is also happe
[
https://issues.apache.org/jira/browse/KAFKA-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4527.
--
Resolution: Fixed
Reviewer: Ewen Cheslack-Postava
> Transient failure
[
https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773299#comment-15773299
]
Ewen Cheslack-Postava commented on KAFKA-4558:
--
There's another
[
https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4553:
-
Status: Patch Available (was: Open)
> Connect's round robin assignment
Ewen Cheslack-Postava created KAFKA-4553:
Summary: Connect's round robin assignment produces undesirable
distribution of connectors/tasks
Key: KAFKA-4553
URL: https://issues.apache.org/jira/browse/
ng, both options
> end
> > up
> > > looking pretty similar (in terms of how transformations are implemented
> > and
> > > the runtime initializes and uses them) and I'm starting to lean towards
> > not
> > > adding a new interface into the mix.
>
Rajini,
Thanks for this KIP, I'd definitely like to see this. Connect has had a
long-standing TODO around stopping sink tasks where we can't properly
manage the rebalance process (which involves stopping consumers) because we
lack a timeout here. Not a huge problem in practice, but would be nice t
Ewen Cheslack-Postava created KAFKA-4527:
Summary: Transient failure of
ConnectDistributedTest.test_pause_and_resume_sink where paused connector
produces messages
Key: KAFKA-4527
URL: https
[
https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743246#comment-15743246
]
Ewen Cheslack-Postava commented on KAFKA-4526:
--
re: related test fail
Ewen Cheslack-Postava created KAFKA-4526:
Summary: Transient failure in
ThrottlingTest.test_throttled_reassignment
Key: KAFKA-4526
URL: https://issues.apache.org/jira/browse/KAFKA-4526
[
https://issues.apache.org/jira/browse/KAFKA-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4140.
--
Resolution: Fixed
Fix Version/s: 0.10.2.0
Issue resolved by pull request
throw new IllegalArgumentException(
> > String.format("Tombstone must be true if null
> value"));
> > }
> > this.topic = topic;
> > this.partition = partition;
> > this.tombstone = tombstone;
> >
+1 (binding)
My only concern was around compatibility. It seems like the one case it is
incompatible would be, at worst, an extremely unusual edge case (and I
*think* can be restricted further to "not source compatible for anyone
extending the affected classes / interfaces and override affected me
e/display/KAFKA/
> Connect+Transforms+-+Proposed+Design
>
> I'd welcome your feedback and comments.
>
> Thanks,
>
> Shikhar
>
> On Tue, Aug 2, 2016 at 7:21 PM Ewen Cheslack-Postava
> wrote:
>
> On Thu, Jul 28, 2016 at 11:58 PM, Shikhar Bhushan
> wrote:
>
>
+1 (binding)
The AdminClient piece will probably need follow up, but given that it's
defined in the context of incomplete KIP-4 design, I'm kind of assuming
it's still up for further discussion once we hit the implementation of that
class (where I think a wholistic view of the API is needed).
Vah
A few thoughts:
> introduce a Streams metadata topic (single partitioned and log compacted;
one for each application-ID)
I would consider whether the single partition is a strict requirement. A
single partition increases the likelihood of outages. This is something I'd
like to see changed in Conn
+1 (binding)
-Ewen
On Sat, Dec 10, 2016 at 2:41 PM, Jay Kreps wrote:
> +1 (binding)
>
> -Jay
>
> On Wed, Dec 7, 2016 at 9:17 AM, Colin McCabe wrote:
>
> > Hi all,
> >
> > I heard that the VOTE and DISCUSS threads for the KIP-97 discussion
> > appeared to be in the same email thread for some pe
It seemed like this was addressed in the migration section, wasn't it? The
V2 vs V3 requests and the fact that the broker will downgrade the message
format (losing zero copy) if you issues a V2 request to a broker using V3
format handles compatibility, does it not? The existing consumers won't see
On Sat, Dec 10, 2016 at 5:23 PM, Sven Ludwig wrote:
> Hi,
>
> as a user I find this concept interesting, but not important enough. I
> just want to share my personal thoughts, potentially leaning myself
> somewhat out of the window, that came to my mind during reading:
>
> - I think it is of utmo
+1 binding
-Ewen
On Tue, Dec 6, 2016 at 3:21 PM, Bill Bejeck wrote:
> +1
>
> On Tue, Dec 6, 2016 at 4:55 PM, Guozhang Wang wrote:
>
> > +1 (binding)
> >
> > On Tue, Dec 6, 2016 at 9:07 AM, Matthias J. Sax
> > wrote:
> >
> > > +1
> > >
> > > On 12/6/16 7:40 AM, Eno Thereska wrote:
> > > > +1 (
[
https://issues.apache.org/jira/browse/KAFKA-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4154.
--
Resolution: Fixed
Reviewer: Ewen Cheslack-Postava
Fix Version/s
[
https://issues.apache.org/jira/browse/KAFKA-4306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4306.
--
Resolution: Fixed
Fix Version/s: 0.10.2.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4161.
--
Resolution: Fixed
Fix Version/s: 0.10.2.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-3008.
--
Resolution: Fixed
Fix Version/s: 0.10.2.0
Issue resolved by pull request
+1 (binding).
Also, see my notes in discussion thread around future compatibility
discussions for breaking plugin interface changes like this.
-Ewen
On Tue, Nov 29, 2016 at 3:54 PM, Guozhang Wang wrote:
> +1.
>
> On Tue, Nov 29, 2016 at 11:05 AM, Bill Bejeck wrote:
>
> > +1 (non-binding)
> >
I think this looks reasonable, but just a more general note on
compatibility -- I think it's worth trying to clarify what types of
compatibility we're trying to achieve. Guozhang's 1 & 2 give an important
breakdown (compile vs runtime compatibility). For the type of change
described here, I think i
[
https://issues.apache.org/jira/browse/KAFKA-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4397.
--
Resolution: Fixed
Issue resolved by pull request 2123
[https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4345:
-
Summary: Run ducktape test for each pull request (was: Run decktape test
for
[
https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava reopened KAFKA-4345:
--
> Run decktape test for each pull requ
[
https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4450:
-
Fix Version/s: (was: 0.10.1.1)
> Add missing 0.10.1.x upgrade tests
[
https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15705874#comment-15705874
]
Ewen Cheslack-Postava commented on KAFKA-4450:
--
Yeah, that makes s
[
https://issues.apache.org/jira/browse/KAFKA-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15699134#comment-15699134
]
Ewen Cheslack-Postava commented on KAFKA-4007:
--
[~enothereska] prefetc
Ewen Cheslack-Postava created KAFKA-4450:
Summary: Add missing 0.10.1.x upgrade tests and ensure ongoing
compatibility checks
Key: KAFKA-4450
URL: https://issues.apache.org/jira/browse/KAFKA-4450
[
https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698985#comment-15698985
]
Ewen Cheslack-Postava commented on KAFKA-3959:
--
[~toddpalino] That'
Generally the producer knows the set of topics it wants to produce to
because it is fixed by the application (even if dynamic, there isn't
commonly much use in exposing this functionality). You're right it could be
implemented, but the use cases seem limited.
If you have a good use case, please fo
When a key is available, you generally include it because you want all
messages with the same key to always end up in the same partition. This
allows all messages with the same key to be processed by the same consumer
(e.g. allowing you to aggregate all data for a single user if you key on
user ID)
[
https://issues.apache.org/jira/browse/KAFKA-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3963:
-
Fix Version/s: (was: 0.10.1.0)
> Missing messages from the controller
[
https://issues.apache.org/jira/browse/KAFKA-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698784#comment-15698784
]
Ewen Cheslack-Postava commented on KAFKA-4449:
--
[~habren] We actually tr
[
https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3400:
-
Fix Version/s: (was: 0.10.1.0)
> Topic stop working / can't descri
[
https://issues.apache.org/jira/browse/KAFKA-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4063:
-
Fix Version/s: (was: 0.10.1.0)
> Add support for infinite endpoints for ra
[
https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-3775:
-
Fix Version/s: (was: 0.10.1.0)
> Throttle maximum number of tasks assigned
[
https://issues.apache.org/jira/browse/KAFKA-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4449:
-
Fix Version/s: (was: 0.10.1.0)
> Add Serializer/Deserializer for P
[
https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4316:
-
Fix Version/s: (was: 0.10.1.0)
> Kafka Streams 0.10.0.1 does not run
[
https://issues.apache.org/jira/browse/KAFKA-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4156:
-
Fix Version/s: (was: 0.10.0.1)
(was: 0.10.0.0)
>
[
https://issues.apache.org/jira/browse/KAFKA-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-4403:
-
Assignee: Balint Molnar (was: Ewen Cheslack-Postava)
> Update KafkaBasedLog
[
https://issues.apache.org/jira/browse/KAFKA-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15696374#comment-15696374
]
Ewen Cheslack-Postava commented on KAFKA-4403:
--
Absolutely, I've
[
https://issues.apache.org/jira/browse/KAFKA-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4417.
--
Resolution: Fixed
Issue resolved by pull request 2144
[https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664439#comment-15664439
]
Ewen Cheslack-Postava commented on KAFKA-4404:
--
What is the motivation
[
https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662738#comment-15662738
]
Ewen Cheslack-Postava commented on KAFKA-3959:
--
[~granthenke] [~onurkar
[
https://issues.apache.org/jira/browse/KAFKA-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-3967.
--
Resolution: Invalid
[~Krishna82] Closing this for now since we haven't
[
https://issues.apache.org/jira/browse/KAFKA-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662381#comment-15662381
]
Ewen Cheslack-Postava commented on KAFKA-4021:
--
[~junrao] Is this actu
The errors you're seeing sound like an issue where you updated the artifact
but didn't recompile against the newer Scala version. Did you recompile or
just replace the Kafka jar with a newer one?
-Ewen
On Wed, Nov 9, 2016 at 4:31 PM, Divyajothi Baskaran
wrote:
> Hi,
> For the past 6 months,I am
[
https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662197#comment-15662197
]
Ewen Cheslack-Postava commented on KAFKA-4402:
--
[~Jun Yao] Sorry, mi
[
https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662198#comment-15662198
]
Ewen Cheslack-Postava commented on KAFKA-4402:
--
[~Jun Yao] Sorry, mi
Ewen Cheslack-Postava created KAFKA-4403:
Summary: Update KafkaBasedLog to use new endOffsets consumer API
Key: KAFKA-4403
URL: https://issues.apache.org/jira/browse/KAFKA-4403
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662153#comment-15662153
]
Ewen Cheslack-Postava commented on KAFKA-4402:
--
[~Jun Yao] Which code
[
https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662147#comment-15662147
]
Ewen Cheslack-Postava commented on KAFKA-4401:
--
[~becket_qin] We'v
[
https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-3829.
--
Resolution: Fixed
Fix Version/s: (was: 0.10.1.1
+1 (binding)
-Ewen
On Wed, Nov 9, 2016 at 2:16 PM, Shikhar Bhushan
wrote:
> Hi,
>
> I would like to initiate a vote on KIP-89
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 89%3A+Allow+sink+connectors+to+decouple+flush+and+offset+commit
>
> Best,
>
> Shikhar
>
--
Thanks,
Ewen
601 - 700 of 2061 matches
Mail list logo
